X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=6f58180f03c4a6a0a4741af5e43ba2c5e6155ca5;hb=4a6907ee4675c3d9bc7fd4ba31a7048527f53a50;hp=994d6572c73744cc5e6bbf3b003aa21d0f5f81c6;hpb=fb966920f18413076a28876ffcd125c84f9a6f06;p=demos%2Fkafka%2Ftraining

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