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 (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;
+       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)
                {