diff --git a/spring-boot-samples/spring-boot-sample-kafka/src/test/java/sample/kafka/SampleKafkaApplicationTests.java b/spring-boot-samples/spring-boot-sample-kafka/src/test/java/sample/kafka/SampleKafkaApplicationTests.java index a7d1b66fc1f..e74f623f691 100644 --- a/spring-boot-samples/spring-boot-sample-kafka/src/test/java/sample/kafka/SampleKafkaApplicationTests.java +++ b/spring-boot-samples/spring-boot-sample-kafka/src/test/java/sample/kafka/SampleKafkaApplicationTests.java @@ -41,7 +41,7 @@ class SampleKafkaApplicationTests { @Test void testVanillaExchange() throws Exception { - long end = System.currentTimeMillis() + 10000; + long end = System.currentTimeMillis() + 30000; while (!this.output.toString().contains("A simple test message") && System.currentTimeMillis() < end) { Thread.sleep(250);