In der letzten Schulung war eine 0 mehr nötig, damit der Fehler auftritt!

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 41916203eed281c786a4c951081d55f43be3bbb8..5877996f4c0663ce989332f15e61ab3dced0b7fe 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -35,7 +35,7 @@ public class ExampleProducer
   {
     try
     {
-      for (int i = 0; i < 10000 ; i++)
+      for (int i = 0; i < 100000 ; i++)
       {
         send(Long.toString(i%10), Long.toString(i));
       }