X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=76cfe42fba38a1e2ec3ff5e48edf54ba3c5cb8e4;hb=96013a5bc40a65eb35713bccc756eea03c4f3de7;hp=71625fd94dbfe83e3db64c5f631a1a9c858ca39f;hpb=f9223ab42c58bf39865fa85dfa6fdaea9ca24b03;p=demos%2Fkafka%2Ftraining

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 71625fd..76cfe42 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -26,8 +26,7 @@ import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.
 
 @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)
@@ -61,6 +60,17 @@ public class ApplicationTests
 				.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
 	{