Tests: Der Test wartet, bis die Offsets regulär committed wurden

[demos/kafka/training] / src / test / java / de / juplo / kafka / ApplicationTests.java

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index bf38b05..f64ab43 100644 (file)
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -84,10 +84,13 @@ class ApplicationTests
                                .atMost(Duration.ofSeconds(30))
                                .until(() -> received.size() >= 100);
 
-               endlessConsumer.stop();
-
-               checkSeenOffsetsForProgress();
-               compareToCommitedOffsets(newOffsets);
+               await("Offsets committed")
+                               .atMost(Duration.ofSeconds(10))
+                               .untilAsserted(() ->
+                               {
+                                       checkSeenOffsetsForProgress();
+                                       compareToCommitedOffsets(newOffsets);
+                               });
        }
 
        @Test