Make consumer groups unique to instance

CDOT-CV · Dec 19, 2024 · 84f77e9 · 84f77e9
1 parent 1c8fc66
commit 84f77e9
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...onflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/kafka/KafkaConsumerConfig.java b/...onflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/kafka/KafkaConsumerConfig.java
@@ -100,6 +100,8 @@ private Map<String, Object> commonProps(final String id)  {
 
         props.put(ConsumerConfig.CLIENT_ID_CONFIG, id);
 
+        // Make the consumer group id be unique to the instance to prevent consumers forming into groups
+        // if running more than one instance
         String groupIdSuffix;
         try {
             groupIdSuffix = InetAddress.getLocalHost().toString();
@@ -109,6 +111,8 @@ private Map<String, Object> commonProps(final String id)  {
         }
         final String groupId = id + "_" + groupIdSuffix;
         props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
+        log.info("Consumer group ID = {}", groupId);
+
         props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
         props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");
         props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, 100);