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=09614b8e23702f729214dd33bc7820ad3c83208d;hb=c808810e9e33afe33b29f7fd3921023ecd15483d;hp=aa3dfd64efd1abcb923c3891745e9d2ea2354f44;hpb=0b6377951bbeeb2443415bc2aa9c68988ee4c5af;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 aa3dfd6..09614b8 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -71,9 +71,9 @@ class ApplicationTests
 	@Autowired
 	PartitionStatisticsRepository repository;
 	@Autowired
-	WordcountRebalanceListener wordcountRebalanceListener;
+	SumRebalanceListener sumRebalanceListener;
 	@Autowired
-	WordcountRecordHandler wordcountRecordHandler;
+	SumRecordHandler sumRecordHandler;
 
 	EndlessConsumer<String, String> endlessConsumer;
 	Map<TopicPartition, Long> oldOffsets;
@@ -243,7 +243,7 @@ class ApplicationTests
 		});
 
 		TestRecordHandler<String, String> captureOffsetAndExecuteTestHandler =
-				new TestRecordHandler<String, String>(wordcountRecordHandler) {
+				new TestRecordHandler<String, String>(sumRecordHandler) {
 					@Override
 					public void onNewRecord(ConsumerRecord<String, String> record)
 					{
@@ -260,7 +260,7 @@ class ApplicationTests
 						properties.getClientId(),
 						properties.getTopic(),
 						kafkaConsumer,
-						wordcountRebalanceListener,
+						sumRebalanceListener,
 						captureOffsetAndExecuteTestHandler);
 
 		endlessConsumer.start();