Update KafkaSampleIntegrationTest.java

Author: rajadilipkolli

kafka-spring-boot/boot-kafka-sample/src/test/java/com/example/springbootkafkasample/KafkaSampleIntegrationTest.java

@@ -48,8 +48,8 @@ void sendAndReceiveMessage() throws Exception {
 
         // 4 from topic1 and 3 from topic2 on startUp, plus 1 from test
         await().pollInterval(Duration.ofSeconds(1))
-                .atMost(Duration.ofSeconds(15))
-                .untilAsserted(() -> assertThat(receiver2.getLatch().getCount()).isEqualTo(2));
+                .atMost(Duration.ofSeconds(30))
+                .untilAsserted(() -> assertThat(receiver2.getLatch().getCount()).isEqualTo(9));
         assertThat(receiver2.getDeadLetterLatch().getCount()).isEqualTo(1);
     }