X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FSplitterApplicationIT.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FSplitterApplicationIT.java;h=a702e1d1be7d711b425c60020b7f24af412df818;hb=cfed6b631771687b645375394c422ec0c02720f5;hp=adf4dde6471544d7f30482db1139706af0530199;hpb=b1db057d3c58d20620482ff68eb210b309e615fe;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationIT.java
index adf4dde..a702e1d 100644
--- a/src/test/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationIT.java
@@ -1,6 +1,7 @@
 package de.juplo.kafka.wordcount.splitter;
 
 import de.juplo.kafka.wordcount.counter.TestWord;
+import de.juplo.kafka.wordcount.recorder.TestRecording;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
@@ -44,7 +45,7 @@ public class SplitterApplicationIT
 	public final static String TOPIC_OUT = "out";
 
 	@Autowired
-	KafkaTemplate<String, Recording> kafkaTemplate;
+	KafkaTemplate<String, TestRecording> kafkaTemplate;
 	@Autowired
 	Consumer consumer;