From fb85d909b34c41df3a11c33649922e1fa90986c9 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 20 Jan 2025 22:38:22 +0100 Subject: [PATCH] Aufruf von `close()` in der Vorlage entfernt --- src/main/java/de/juplo/kafka/ExampleProducer.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java index 2386d95d..57d27fba 100644 --- a/src/main/java/de/juplo/kafka/ExampleProducer.java +++ b/src/main/java/de/juplo/kafka/ExampleProducer.java @@ -51,8 +51,6 @@ public class ExampleProducer } finally { - log.info("{}: Closing the KafkaProducer", id); - producer.close(); log.info("{}: Produced {} messages in total, exiting!", id, produced); done = true; } -- 2.20.1