X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fcounter%2FCounterApplicationIT.java;h=5a3507ac0611cef4a87e34288b4a2cca7b9af675;hb=refs%2Ftags%2Fcounter-1.2.12;hp=e0f46723524edcfb31c27c34007770847ed347bc;hpb=b67e6b91cf7fd378fb78f0ad9e2fd47c21fbf726;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
index e0f4672..5a3507a 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
@@ -76,16 +76,16 @@ public class CounterApplicationIT
 	@RequiredArgsConstructor
 	static class Consumer
 	{
-		private final List<KeyValue<Word, WordCount>> received = new LinkedList<>();
+		private final List<KeyValue<Word, WordCounter>> received = new LinkedList<>();
 
 		@KafkaListener(groupId = "TEST", topics = TOPIC_OUT)
-		public synchronized void receive(ConsumerRecord<Word, WordCount> record)
+		public synchronized void receive(ConsumerRecord<Word, WordCounter> record)
 		{
 			log.debug("Received message: {}", record);
 			received.add(KeyValue.pair(record.key(),record.value()));
 		}
 
-		synchronized List<KeyValue<Word, WordCount>> getReceivedMessages()
+		synchronized List<KeyValue<Word, WordCounter>> getReceivedMessages()
 		{
 			return received;
 		}