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;
public final static String TOPIC_OUT = "out";
@Autowired
- KafkaTemplate<String, Recording> kafkaTemplate;
+ KafkaTemplate<String, TestRecording> kafkaTemplate;
@Autowired
Consumer consumer;