import static de.juplo.kafka.wordcount.recorder.RecorderApplicationIT.TOPIC_OUT;
import static org.assertj.core.api.Assertions.assertThat;
import static de.juplo.kafka.wordcount.recorder.RecorderApplicationIT.TOPIC_OUT;
import static org.assertj.core.api.Assertions.assertThat;