@SpringBootTest(
properties = {
- "spring.kafka.consumer.bootstrap-servers=${spring.embedded.kafka.brokers}",
- "producer.bootstrap-server=${spring.embedded.kafka.brokers}",
+ "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
"producer.topic=" + TOPIC})
@AutoConfigureMockMvc
@EmbeddedKafka(topics = TOPIC, partitions = PARTITIONS)
@Test
- void testSendMessage() throws Exception
+ void testSendClientMessage() throws Exception
{
mockMvc
.perform(post("/peter").content("Hallo Welt!"))
.until(() -> consumer.received.size() == 1);
}
+ @Test
+ void testSendFooMessage() throws Exception
+ {
+ mockMvc
+ .perform(put("/peter"))
+ .andExpect(status().isOk());
+ await("Message was send")
+ .atMost(Duration.ofSeconds(5))
+ .until(() -> consumer.received.size() == 1);
+ }
+
+ @Test
+ void testSendGreeting() throws Exception
+ {
+ mockMvc
+ .perform(post("/").content("peter"))
+ .andExpect(status().isOk());
+ await("Message was send")
+ .atMost(Duration.ofSeconds(5))
+ .until(() -> consumer.received.size() == 1);
+ }
+
static class Consumer
{