Nachrichten zählen

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 080102dc96c85d1c66eed6020f708e26d3b05709..a581e5b2869f8b7ca48d16198aab5a220d669372 100644 (file)
--- 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;
     }
   }