From: Kai Moritz <kai@juplo.de>
Date: Mon, 11 Apr 2022 07:41:40 +0000 (+0200)
Subject: Tests: Der Test wartet, bis die Offsets regulär committed wurden
X-Git-Tag: wip-DEPRECATED~11^2^2~13
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=b7d02b89c884eeaf864e5c86c30c7313a7b1036e;p=demos%2Fkafka%2Ftraining

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

* 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.
---

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