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 2386d95da55983368b6428eb6ce7db618c15911d..57d27fbae1aca97db17c3adf94b15c5ad705a89a 100644 (file)
--- 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;
     }