Sporadische Timing-Fehler in dem Test ausgeschlossen
[demos/kafka/training] / src / test / java / de / juplo / kafka / ApplicationTests.java
index 43a4f61..7ec73f3 100644 (file)
@@ -153,6 +153,7 @@ class ApplicationTests
 
                await("Offsets committed")
                                .atMost(Duration.ofSeconds(10))
+                               .pollDelay(Duration.ofSeconds(1))
                                .untilAsserted(() ->
                                {
                                        checkSeenOffsetsForProgress();