Der supersimple Producer schreibt endlos...

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index ba95dfb8fc3baf8c73c5c076d4fbfd50fb77b88f..09cd323fd399cc8e387578e1eb92ca49fdd3580a 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -23,7 +23,7 @@ public class ExampleProducer implements ApplicationRunner
   @Override
   public void run(ApplicationArguments args)
   {
-    for (int i = 0; i < 100; i++)
+    for (int i = 0; true; i++)
     {
       // end::supersimple[]
       // tag::callback[]