From: Kai Moritz Date: Mon, 20 Jan 2025 21:38:22 +0000 (+0100) Subject: Aufruf von `close()` in der Vorlage entfernt X-Git-Tag: grundlagen/simple-producer--vorlage--2025-01-signal~1 X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=327cba908a0ca80d261468869c81cf33cc453275;p=demos%2Fkafka%2Ftraining Aufruf von `close()` in der Vorlage entfernt --- 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; }