From: Kai Moritz <kai@juplo.de>
Date: Mon, 11 Apr 2022 14:19:44 +0000 (+0200)
Subject: Tests: Geprüft, dass der Fehler nach einem Neustart neu vorliegt
X-Git-Tag: sumup-requests---lvm-2-tage~5^2^2^2~2^2~10
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;ds=sidebyside;h=4a6907ee4675c3d9bc7fd4ba31a7048527f53a50;p=demos%2Fkafka%2Ftraining

Tests: Geprüft, dass der Fehler nach einem Neustart neu vorliegt
---

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 994d657..6f58180 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -110,6 +110,14 @@ class ApplicationTests
 
 		checkSeenOffsetsForProgress();
 		compareToCommitedOffsets(newOffsets);
+
+		endlessConsumer.start();
+		await("Consumer failed")
+				.atMost(Duration.ofSeconds(30))
+				.until(() -> !endlessConsumer.running());
+
+		checkSeenOffsetsForProgress();
+		compareToCommitedOffsets(newOffsets);
 	}