X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FGenericApplicationTests.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FGenericApplicationTests.java;h=1aacb945c5d62495ef45d01aad5669e8bfa3cc0b;hb=27768041f2c2f4b1cbb8c45c9a5d665490050f76;hp=8b9a3ff367230b759f7b03770e8e5fa4561deb6a;hpb=c6a33a3c27563018d99a56fe4069f20de64e9f4c;p=demos%2Fkafka%2Ftraining

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