Wordcount-Implementierung mit Kafka-Boardmitteln und MongoDB als Storage

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

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index ca72e3c..aa6dd4d 100644 (file)
--- 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();
        }