Fire & Forget

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 73aa8e9..efdbb8d 100644 (file)
--- 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...");