From: Kai Moritz <kai@juplo.de>
Date: Sat, 21 Mar 2026 19:16:36 +0000 (+0100)
Subject: Nachrichten zählen
X-Git-Tag: grundlagen/simple-producer--livecoding--schritte--2026-03-22--20-47~1
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=d9e6ea37230ad9bca1ad49098fafe992385c0121;p=demos%2Fkafka%2Ftraining

Nachrichten zählen
---

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;
     }
   }