watConsumer group id defined in app_prop

sunbird-cb · Jul 20, 2022 · 6f7ad89 · 6f7ad89
1 parent 45d4e9d
commit 6f7ad89
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git 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<String, String> data) {
 		try {
 			logger.info("Consuming the audit records for WAT .....");

diff --git 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