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

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

diff --git a/src/test/java/de/juplo/kafka/GenericApplicationTests.java b/src/test/java/de/juplo/kafka/GenericApplicationTests.java
index 8b9a3ff..1aacb94 100644 (file)
--- 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);