From: Kai Moritz <kai@juplo.de>
Date: Mon, 28 Oct 2024 09:49:26 +0000 (+0100)
Subject: Log-Meldungen für das Senden des Zählerstands ergänzt
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=38bfee6f2546decf5d2a7ffee3ad8cebd135ae58;p=demos%2Fkafka%2Ftraining

Log-Meldungen für das Senden des Zählerstands ergänzt
---

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index f4cad5c..119badd 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -223,12 +223,22 @@ public class ExampleConsumer implements Runnable, ConsumerRebalanceListener
   public void onPartitionsAssigned(Collection<TopicPartition> partitions)
   {
     phaser.bulkRegister(partitions.size());
+    log.info(
+      "{} - Added {} parties for newly assigned partitions. New total number of parties: {}",
+      id,
+      partitions.size(),
+      phaser.getRegisteredParties());
   }
 
   @Override
   public void onPartitionsRevoked(Collection<TopicPartition> partitions)
   {
     partitions.forEach(partition -> phaser.arriveAndDeregister());
+    log.info(
+      "{} - Removed {} parties for revoked partitions. New total number of parties: {}",
+      id,
+      partitions.size(),
+      phaser.getRegisteredParties());
   }
 
   public void shutdown() throws InterruptedException