From 4a6907ee4675c3d9bc7fd4ba31a7048527f53a50 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 11 Apr 2022 16:19:44 +0200
Subject: [PATCH] =?utf8?q?Tests:=20Gepr=C3=BCft,=20dass=20der=20Fehler=20n?=
 =?utf8?q?ach=20einem=20Neustart=20neu=20vorliegt?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 src/test/java/de/juplo/kafka/ApplicationTests.java | 8 ++++++++
 1 file changed, 8 insertions(+)

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);
 	}
 
 
-- 
2.20.1