From: Kai Moritz <kai@juplo.de>
Date: Sun, 24 Jul 2022 18:37:17 +0000 (+0200)
Subject: WIP
X-Git-Tag: wip-DEPRECATED
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ed3aa1d7cc35eb3a4c75fe527445ffe0901d62b8;p=demos%2Fkafka%2Ftraining

WIP
---

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 9d5fb52..2247d9e 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;
+	Wordcount<String, String> wordcount;
 	Map<TopicPartition, Long> oldOffsets;
 	Map<TopicPartition, Long> newOffsets;
 	Set<ConsumerRecord<String, String>> receivedRecords;
@@ -99,7 +99,7 @@ class ApplicationTests
 				});
 
 		assertThatExceptionOfType(IllegalStateException.class)
-				.isThrownBy(() -> endlessConsumer.exitStatus())
+				.isThrownBy(() -> wordcount.exitStatus())
 				.describedAs("Consumer should still be running");
 	}
 
@@ -224,7 +224,7 @@ class ApplicationTests
 					testHandler.accept(record);
 				};
 
-		endlessConsumer =
+		wordcount =
 				new EndlessConsumer<>(
 						executor,
 						repository,
@@ -235,7 +235,7 @@ class ApplicationTests
 						kafkaConsumer,
 						captureOffsetAndExecuteTestHandler);
 
-		endlessConsumer.start();
+		wordcount.start();
 	}
 
 	@AfterEach
@@ -243,7 +243,7 @@ class ApplicationTests
 	{
 		try
 		{
-			endlessConsumer.stop();
+			wordcount.stop();
 		}
 		catch (Exception e)
 		{