X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=7ec73f353278aa29f8f76ddf7b1f3eeac7896422;hb=7819bf5f7f5b875d14a2cbb2d435a6652e46b4ae;hp=43a4f6124d8fa931b0791149f84227959352ad2d;hpb=1709f0e4f41be7e3b955d19769697a517633827d;p=demos%2Fkafka%2Ftraining

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 43a4f61..7ec73f3 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -153,6 +153,7 @@ class ApplicationTests
 
 		await("Offsets committed")
 				.atMost(Duration.ofSeconds(10))
+				.pollDelay(Duration.ofSeconds(1))
 				.untilAsserted(() ->
 				{
 					checkSeenOffsetsForProgress();