X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=aa6dd4d21afd5f17ebf3aaf5640062318f4f2c44;hb=a6a0a22a5fa34a01b0e8b2bc1e0e2b82d7b60f33;hp=ca72e3c552fe10bdd9cea727da1f2dd199449a70;hpb=60bc4a251dc9bab71d5ab5f12870147fec253ac9;p=demos%2Fkafka%2Ftraining

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index ca72e3c..aa6dd4d 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -73,7 +73,7 @@ class ApplicationTests
 	PartitionStatisticsRepository repository;
 
 	Consumer<ConsumerRecord<String, String>> testHandler;
-	EndlessConsumer<String, String> endlessConsumer;
+	EndlessConsumer endlessConsumer;
 	Map<TopicPartition, Long> oldOffsets;
 	Map<TopicPartition, Long> newOffsets;
 	Set<ConsumerRecord<String, String>> receivedRecords;
@@ -228,15 +228,14 @@ class ApplicationTests
 				};
 
 		endlessConsumer =
-				new EndlessConsumer<>(
+				new EndlessConsumer(
 						executor,
 						repository,
 						properties.getClientId(),
 						properties.getTopic(),
 						Clock.systemDefaultZone(),
 						properties.getCommitInterval(),
-						kafkaConsumer,
-						captureOffsetAndExecuteTestHandler);
+						kafkaConsumer);
 
 		endlessConsumer.start();
 	}