From: Kai Moritz <kai@juplo.de>
Date: Tue, 1 Apr 2025 18:17:49 +0000 (+0200)
Subject: Fire & Forget
X-Git-Tag: grundlagen/simple-producer--livecoding--schritte--2026-06-lvm
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=f234fd76cbf08f86aa1892046b8838d6173bf175;p=demos%2Fkafka%2Ftraining

Fire & Forget
---

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