Log-Meldungen zum Fortschritt beim Versenden des Zähler-Status ergänzt

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index eaa6f53..2dfc2a4 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -196,7 +196,24 @@ public class ExampleConsumer implements Runnable, ConsumerRebalanceListener
       acked[partition]++;
       if (done[partition] && !(acked[partition] < seen[partition]))
       {
-        phaser.arrive();
+        int arrivedPhase = phaser.arrive();
+        log.debug(
+            "{} - Arrived at phase {} for partition {}, seen={}, acked={}",
+            id,
+            arrivedPhase,
+            partition,
+            seen[partition],
+            acked[partition]);
+      }
+      else
+      {
+        log.debug(
+            "{} - Still in phase {} for partition {}, seen={}, acked={}",
+            id,
+            phaser.getPhase(),
+            partition,
+            seen[partition],
+            acked[partition]);
       }
     });