diff --git a/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/groupId/MainLiveTest.java b/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/groupId/MainLiveTest.java index dad1dbbf5d..338ed2855f 100644 --- a/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/groupId/MainLiveTest.java +++ b/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/groupId/MainLiveTest.java @@ -33,9 +33,7 @@ public class MainLiveTest { @Test public void givenEmbeddedKafkaBroker_whenSendingWithSimpleProducer_thenMessageReceived() throws Exception { String data = "Test 123..."; - producer.send(data); - boolean messageConsumed = consumer.getLatch() .await(10, TimeUnit.SECONDS); assertTrue(messageConsumed);