From: Kai Moritz <kai@juplo.de>
Date: Sun, 14 Aug 2022 13:26:26 +0000 (+0200)
Subject: Anzahl der erzeugten Test-Nachrichten wird vom `RecordGenerator` bestimmt
X-Git-Tag: sumup-adder---lvm-2-tage~9^2~4
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=27768041f2c2f4b1cbb8c45c9a5d665490050f76;p=demos%2Fkafka%2Ftraining

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

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 51d579e..1272124 100644
--- 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));
diff --git a/src/test/java/de/juplo/kafka/GenericApplicationTests.java b/src/test/java/de/juplo/kafka/GenericApplicationTests.java
index 8b9a3ff..1aacb94 100644
--- a/src/test/java/de/juplo/kafka/GenericApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/GenericApplicationTests.java
@@ -239,7 +239,6 @@ abstract class GenericApplicationTests<K, V>
 	public interface RecordGenerator
 	{
 		void generate(
-				int numberOfMessagesToGenerate,
 				Set<Integer> poisonPills,
 				Set<Integer> logicErrors,
 				Consumer<ProducerRecord<Bytes, Bytes>> messageSender);