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=660fe128040e6e0d06745cdc01aaa749dc72f41a;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 9dafb18..89cfd0a 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -231,12 +231,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