add group to factory build

US-ELRR · Jun 14, 2024 · 63ad889 · 63ad889
1 parent 93f8bab
commit 63ad889
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/deloitte/elrr/elrrconsolidate/consumer/KafkaConsumerConfig.java b/src/main/java/com/deloitte/elrr/elrrconsolidate/consumer/KafkaConsumerConfig.java
@@ -34,7 +34,7 @@ public ConsumerFactory<String, String> consumerFactory() {
         log.info("Start building Kafka Consumer factory");
         Map<String, Object> props = new HashMap<>();
         props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, brokerUrl);
-        // props.put(ConsumerConfig.GROUP_ID_CONFIG, "test-group");
+        props.put(ConsumerConfig.GROUP_ID_CONFIG, "test-group");
         props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
                 StringDeserializer.class);
         props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,