From a71d5ef5725d71e847ca51a03c9a77080bc2e280 Mon Sep 17 00:00:00 2001 From: ase-101 Date: Mon, 18 Nov 2024 20:32:05 +0530 Subject: [PATCH] ES-1929 (#1007) Signed-off-by: ase-101 --- .../io/mosip/esignet/services/AuthorizationHelperService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/oidc-service-impl/src/main/java/io/mosip/esignet/services/AuthorizationHelperService.java b/oidc-service-impl/src/main/java/io/mosip/esignet/services/AuthorizationHelperService.java index b9405ffd1..a4095bc2e 100644 --- a/oidc-service-impl/src/main/java/io/mosip/esignet/services/AuthorizationHelperService.java +++ b/oidc-service-impl/src/main/java/io/mosip/esignet/services/AuthorizationHelperService.java @@ -146,7 +146,7 @@ protected void addEntryInLinkAuthCodeStatusDeferredResultMap(String key, Deferre LINK_AUTH_CODE_STATUS_DEFERRED_RESULT_MAP.put(key, deferredResult); } - @KafkaListener(id = "link-status-consumer", autoStartup = "${kafka.enabled:true}", topics = "${mosip.esignet.kafka.linked-session.topic}") + @KafkaListener(id = "${spring.kafka.consumer.group-id}"+"-link-status", autoStartup = "${kafka.enabled:true}", topics = "${mosip.esignet.kafka.linked-session.topic}") public void consumeLinkStatus(String linkCodeHash) { DeferredResult deferredResult = LINK_STATUS_DEFERRED_RESULT_MAP.get(linkCodeHash); if(deferredResult != null) { @@ -156,7 +156,7 @@ public void consumeLinkStatus(String linkCodeHash) { } } - @KafkaListener(id = "link-auth-code-status-consumer", autoStartup = "${kafka.enabled:true}", topics = "${mosip.esignet.kafka.linked-auth-code.topic}") + @KafkaListener(id = "${spring.kafka.consumer.group-id}"+"-linked-auth-code", autoStartup = "${kafka.enabled:true}", topics = "${mosip.esignet.kafka.linked-auth-code.topic}") public void consumeLinkAuthCodeStatus(String linkTransactionId) { DeferredResult deferredResult = LINK_AUTH_CODE_STATUS_DEFERRED_RESULT_MAP.get(linkTransactionId); if(deferredResult != null) {