From 27768041f2c2f4b1cbb8c45c9a5d665490050f76 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 14 Aug 2022 15:26:26 +0200
Subject: [PATCH] Anzahl der erzeugten Test-Nachrichten wird vom
 `RecordGenerator` bestimmt

---
 src/test/java/de/juplo/kafka/ApplicationTests.java        | 3 +--
 src/test/java/de/juplo/kafka/GenericApplicationTests.java | 1 -
 2 files changed, 1 insertion(+), 3 deletions(-)

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);
-- 
2.20.1