diff --git a/src/main/java/com/deloitte/elrr/elrrconsolidate/consumer/KafkaConsumerConfig.java b/src/main/java/com/deloitte/elrr/elrrconsolidate/consumer/KafkaConsumerConfig.java
index b08867c..2c51bd6 100644
--- 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,