From 63d1ddaea31c195a97ad9dde9c635e390f166930 Mon Sep 17 00:00:00 2001 From: cesarevalenti90 <50798547+cesarevalenti90@users.noreply.github.com> Date: Mon, 9 Jan 2023 22:16:44 +0100 Subject: [PATCH] fix retry test (#13267) Co-authored-by: Cesare --- .../baeldung/spring/kafka/KafkaRetryableIntegrationTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-kafka/src/test/java/com/baeldung/spring/kafka/KafkaRetryableIntegrationTest.java b/spring-kafka/src/test/java/com/baeldung/spring/kafka/KafkaRetryableIntegrationTest.java index 029031923e..5417fee1ac 100644 --- a/spring-kafka/src/test/java/com/baeldung/spring/kafka/KafkaRetryableIntegrationTest.java +++ b/spring-kafka/src/test/java/com/baeldung/spring/kafka/KafkaRetryableIntegrationTest.java @@ -57,7 +57,7 @@ public class KafkaRetryableIntegrationTest { Greeting greeting = new Greeting("test1", "test2"); container.start(); template.send(TOPIC, objectMapper.writeValueAsString(greeting)); - assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue(); + assertThat(latch.await(10, TimeUnit.SECONDS)).isFalse(); } @Test @@ -78,7 +78,7 @@ public class KafkaRetryableIntegrationTest { //this message will go on error Greeting greeting2 = new Greeting("test2", "test2"); template.send(TOPIC, objectMapper.writeValueAsString(greeting2)); - assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue(); + assertThat(latch.getCount()).isEqualTo(1); } }