From d9e6ea37230ad9bca1ad49098fafe992385c0121 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 21 Mar 2026 20:16:36 +0100
Subject: [PATCH] =?utf8?q?Nachrichten=20z=C3=A4hlen?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 src/main/java/de/juplo/kafka/ExampleProducer.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 080102dc..a581e5b2 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -51,13 +51,14 @@ public class ExampleProducer
         producer.send(record);
 
         log.debug("{} - Sent message {}={}", id, record.key(), record.value());
+        produced++;
 
         Thread.sleep(500);
       }
     }
     finally
     {
-      log.info("{}: Exiting!", id);
+      log.info("{}: Produced {} messages in total, exiting!", id, produced);
       done = true;
     }
   }
-- 
2.39.5