- endlessConsumer.stop();
-
- checkSeenOffsetsForProgress();
- compareToCommitedOffsets(newOffsets);
+ await("Offsets committed")
+ .atMost(Duration.ofSeconds(10))
+ .untilAsserted(() ->
+ {
+ checkSeenOffsetsForProgress();
+ compareToCommitedOffsets(newOffsets);
+ });