import java.time.Duration;
-import static de.juplo.kafka.wordcount.splitter.SplitterApplicationTests.*;
+import static de.juplo.kafka.wordcount.splitter.SplitterApplicationIT.*;
import static org.assertj.core.api.Assertions.assertThat;
import static org.awaitility.Awaitility.*;
"juplo.wordcount.splitter.output-topic=" + TOPIC_OUT })
@EmbeddedKafka(topics = { TOPIC_IN, TOPIC_OUT }, partitions = PARTITIONS)
@Slf4j
-public class SplitterApplicationTests
+public class SplitterApplicationIT
{
public final static String TOPIC_IN = "in";
public final static String TOPIC_OUT = "out";