iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BAEL-7351 removed new lines

Browse Source
This commit is contained in:
s9m33r 2024-02-04 11:38:52 +05:30
parent e7be980d34
commit 95379f73cc
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
spring-kafka-2/src/test/java/com/baeldung/spring/kafka/groupId/MainLiveTest.java
View File

@ -33,9 +33,7 @@ public class MainLiveTest {
@Test @Test
public void givenEmbeddedKafkaBroker_whenSendingWithSimpleProducer_thenMessageReceived() throws Exception { public void givenEmbeddedKafkaBroker_whenSendingWithSimpleProducer_thenMessageReceived() throws Exception {
String data = "Test 123..."; String data = "Test 123...";
producer.send(data); producer.send(data);
boolean messageConsumed = consumer.getLatch() boolean messageConsumed = consumer.getLatch()
.await(10, TimeUnit.SECONDS); .await(10, TimeUnit.SECONDS);
assertTrue(messageConsumed); assertTrue(messageConsumed);