Anzahl der erzeugten Test-Nachrichten wird vom `RecordGenerator` bestimmt

[demos/kafka/training] / src / test / java / de / juplo / kafka / ApplicationTests.java

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 51d579e..1272124 100644 (file)
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -28,7 +28,6 @@ public class ApplicationTests extends GenericApplicationTests<String, Long>
 
           @Override
           public void generate(
-              int numberOfMessagesToGenerate,
               Set<Integer> poisonPills,
               Set<Integer> logicErrors,
               Consumer<ProducerRecord<Bytes, Bytes>> messageSender)
@@ -39,7 +38,7 @@ public class ApplicationTests extends GenericApplicationTests<String, Long>
             {
               for (int key = 0; key < 10; key++)
               {
-                if (++i > numberOfMessagesToGenerate)
+                if (++i > 100)
                   return;
 
                 Bytes value = new Bytes(longSerializer.serialize(TOPIC, (long)i));