From cd9fd2943ab42333f217b210fdca2e72ce080f53 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Tue, 1 Apr 2025 20:17:49 +0200
Subject: [PATCH] Fire & Forget
---
src/main/java/de/juplo/kafka/ExampleProducer.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 73aa8e9..efdbb8d 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -53,12 +53,11 @@ public class ExampleProducer
producer.send(record);
produced++;
- log.info("{}: Send message {}", id, i);
- Thread.sleep(500);
}
}
finally
{
+ producer.close();
done = true;
log.info("{}: Produced {} messages in total, exiting!", id, produced);
}
@@ -88,7 +87,7 @@ public class ExampleProducer
instance.running = false;
while(!instance.done) {
try {
- Thread.sleep(10);
+ Thread.sleep(1);
}
catch (Exception e) {}
log.info("Waiting...");
--
2.20.1