import static de.juplo.kafka.wordcount.splitter.SplitterApplicationIT.TOPIC_IN;
import static de.juplo.kafka.wordcount.splitter.SplitterApplicationIT.TOPIC_OUT;
import static de.juplo.kafka.wordcount.splitter.SplitterApplicationIT.TOPIC_IN;
import static de.juplo.kafka.wordcount.splitter.SplitterApplicationIT.TOPIC_OUT;
public static void testSendMessage(
@Autowired KafkaTemplate<String, TestRecording> kafkaTemplate)
{
public static void testSendMessage(
@Autowired KafkaTemplate<String, TestRecording> kafkaTemplate)
{