task-dep-kafka-done

yacekmm · Dec 6, 2024 · 64b5bcc · 64b5bcc
1 parent 84e7d73
commit 64b5bcc
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/services/Promoter/src/test/java/com/bottega/promoter/infra/TestKafkaEventListener.java b/services/Promoter/src/test/java/com/bottega/promoter/infra/TestKafkaEventListener.java
@@ -11,7 +11,6 @@
 import org.springframework.messaging.Message;
 import org.springframework.stereotype.Component;
 import org.testcontainers.shaded.org.awaitility.Awaitility;
-import static org.assertj.core.api.Assertions.assertThat;
 
 @Component
 @RequiredArgsConstructor
@@ -36,8 +35,7 @@ public void tearDown() {
     }
 
     public Event singleEvent() {
-        //TODO tests are unstable as kafka listener is not always ready
-        assertThat(receivedEvents).hasSize(1);
+        Awaitility.await().until(() -> receivedEvents.size() == 1);
         return receivedEvents.getFirst();
     }
 }