From b7d02b89c884eeaf864e5c86c30c7313a7b1036e Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 11 Apr 2022 09:41:40 +0200
Subject: [PATCH] =?utf8?q?Tests:=20Der=20Test=20wartet,=20bis=20die=20Offs?=
 =?utf8?q?ets=20regul=C3=A4r=20committed=20wurden?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

* Zuvor wurde der Offset-Commit erzwungen, indem der EndlessConsumer
  über den Aufruf von `stop()` beendet wurde.
* Jetzt wird die Überprüfung der Erwartungen über awaitility aufgeschoben,
  bis die Erwartungen beobachtet werden können - oder eine Zeitschranke
  gerissen wird.
---
 src/test/java/de/juplo/kafka/ApplicationTests.java | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index bf38b05..f64ab43 100644
--- 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
-- 
2.20.1