- .until(() -> !endlessConsumer.running());
-
- checkSeenOffsetsForProgress();
- assertSeenOffsetsEqualCommittedOffsets(recordHandler.seenOffsets);
- assertThat(recordHandler.receivedMessages)
- .describedAs("Received not all sent events")
- .isLessThan(numberOfGeneratedMessages);
+ .untilAsserted(() ->
+ {
+ checkSeenOffsetsForProgress();
+ assertSeenOffsetsEqualCommittedOffsets(recordHandler.seenOffsets);
+ });