import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.test.context.EmbeddedKafka;
import org.springframework.test.web.servlet.MockMvc;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.test.context.EmbeddedKafka;
import org.springframework.test.web.servlet.MockMvc;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import static de.juplo.kafka.wordcount.recorder.ApplicationTests.PARTITIONS;
import static de.juplo.kafka.wordcount.recorder.ApplicationTests.TOPIC_OUT;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import static de.juplo.kafka.wordcount.recorder.ApplicationTests.PARTITIONS;
import static de.juplo.kafka.wordcount.recorder.ApplicationTests.TOPIC_OUT;
import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
.perform(post("/{user}", USER)
.contentType(MediaType.TEXT_PLAIN)
.content(SENTENCE))
.perform(post("/{user}", USER)
.contentType(MediaType.TEXT_PLAIN)
.content(SENTENCE))