From 4f51e5829c9e68a4d4802d5539457a3859b62ba8 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 24 Jan 2024 23:30:57 +0100 Subject: [PATCH] WIP --- src/test/java/de/juplo/kafka/ApplicationTests.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java index c861034..567389d 100644 --- a/src/test/java/de/juplo/kafka/ApplicationTests.java +++ b/src/test/java/de/juplo/kafka/ApplicationTests.java @@ -13,8 +13,7 @@ import java.util.concurrent.CompletableFuture; import static de.juplo.kafka.ApplicationTests.PARTITIONS; import static de.juplo.kafka.ApplicationTests.TOPIC; -import static org.assertj.core.api.Assertions.assertThat; -import static org.assertj.core.api.Assertions.assertThatThrownBy; +import static org.assertj.core.api.Assertions.*; import static org.awaitility.Awaitility.*; @@ -74,6 +73,7 @@ public class ApplicationTests assertThat(resultB2.isCompletedExceptionally()).isFalse(); assertThatThrownBy(() -> instanceA.commit()).isInstanceOf(InvalidProducerEpochException.class); - instanceB.commit(); + assertThatCode(() -> instanceB.commit()).doesNotThrowAnyException(); } } +â \ No newline at end of file -- 2.20.1