From 7f8015ae6a9fa3eb454313af0affe18664446392 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 1 Apr 2025 20:17:49 +0200 Subject: [PATCH] Fire & Forget --- src/main/java/de/juplo/kafka/ExampleProducer.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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; } -- 2.39.5