From 6f7ad89a3688a6a75943fdc8d6a077e210d99912 Mon Sep 17 00:00:00 2001 From: wilkysingh-tarento Date: Wed, 20 Jul 2022 16:32:35 +0530 Subject: [PATCH] watConsumer group id defined in app_prop --- .../java/org/sunbird/workallocation/service/WATConsumer.java | 2 +- src/main/resources/application.properties | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/org/sunbird/workallocation/service/WATConsumer.java b/src/main/java/org/sunbird/workallocation/service/WATConsumer.java index 3daa986b6..9853456e9 100644 --- a/src/main/java/org/sunbird/workallocation/service/WATConsumer.java +++ b/src/main/java/org/sunbird/workallocation/service/WATConsumer.java @@ -62,7 +62,7 @@ public class WATConsumer { private static final String[] ignorableFieldsForPublishedState = { "userName", "userEmail", "submittedFromName", "submittedFromEmail", "submittedToName", "submittedToEmail", "createdByName", "updatedByName" }; - @KafkaListener(id = "id2", topics = "${kafka.topics.wat.telemetry.event}", groupId = "watTelemetryTopic-consumer") + @KafkaListener(id = "id2", topics = "${kafka.topics.wat.telemetry.event}", groupId = "${kafka.topics.wat.telemetry.event.topic.consumer}") public void processMessage(ConsumerRecord data) { try { logger.info("Consuming the audit records for WAT ....."); diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 60fa7977f..41ec16dea 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -66,6 +66,7 @@ kafka.topics.wat.telemetry.event=watTelemetryTopic kafka.topics.parent.telemetry.event=dev.telemetry.raw kafka.topics.parent.rating.event = dev.rating.event kafka.topics.userutility.telemetry.event=userLastLoginTopic +kafka.topics.wat.telemetry.event.topic.consumer=watTelemetryTopic-consumer userutility.telemetry.event.pdata.id=dev.sunbird.cb.ext.service userutility.telemetry.event.pdata.pid=sunbird-cb-ext-service