chore(server): logs core topology KafkaStreams state (#854)

littlehorse-enterprises · Jun 3, 2024 · f85aeeb · f85aeeb
1 parent 31e7b68
commit f85aeeb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/server/src/main/java/io/littlehorse/server/monitoring/metrics/InstanceState.java b/server/src/main/java/io/littlehorse/server/monitoring/metrics/InstanceState.java
@@ -78,6 +78,7 @@ public void onChange(KafkaStreams.State newState, KafkaStreams.State oldState) {
             activeTasks.set(currentActiveTaskIds);
             internalComms.handleRebalance(activeTasks.get());
         }
+        log.info("New state for core topology: {}", newState);
     }
 
     @Override