diff --git a/core/src/test/java/kafka/test/api/ShareConsumerTest.java b/core/src/test/java/kafka/test/api/ShareConsumerTest.java index 89b357cf4c347..303f390363c53 100644 --- a/core/src/test/java/kafka/test/api/ShareConsumerTest.java +++ b/core/src/test/java/kafka/test/api/ShareConsumerTest.java @@ -275,7 +275,6 @@ public void testSubscriptionAndPollMultiple(String persister) { } } - @Flaky("KAFKA-18033") @ParameterizedTest(name = "{displayName}.persister={0}") @ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER}) public void testAcknowledgementSentOnSubscriptionChange(String persister) throws ExecutionException, InterruptedException { @@ -599,7 +598,6 @@ public void testExplicitAcknowledgeCommitSuccess(String persister) { } } - @Flaky("KAFKA-18033") @ParameterizedTest(name = "{displayName}.persister={0}") @ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER}) public void testExplicitAcknowledgementCommitAsync(String persister) throws InterruptedException { @@ -656,7 +654,6 @@ public void testExplicitAcknowledgementCommitAsync(String persister) throws Inte } } - @Flaky("KAFKA-18033") @ParameterizedTest(name = "{displayName}.persister={0}") @ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER}) public void testExplicitAcknowledgementCommitAsyncPartialBatch(String persister) { @@ -763,7 +760,6 @@ public void testExplicitAcknowledgeReleaseAccept(String persister) { } } - @Flaky("KAFKA-18033") @ParameterizedTest(name = "{displayName}.persister={0}") @ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER}) public void testExplicitAcknowledgeReleaseClose(String persister) { @@ -1188,7 +1184,6 @@ public void testMultipleConsumersInGroupFailureConcurrentConsumption(String pers assertEquals(producerCount * messagesPerProducer, totalSuccessResult); } - @Flaky("KAFKA-18025") @ParameterizedTest(name = "{displayName}.persister={0}") @ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER}) public void testAcquisitionLockTimeoutOnConsumer(String persister) throws InterruptedException { @@ -1296,7 +1291,6 @@ public void onComplete(Map> offsetsMap, Exception ex * Test to verify that the acknowledgement commit callback can invoke KafkaShareConsumer.wakeup() and it * wakes up the enclosing poll. */ - @Flaky("KAFKA-18033") @ParameterizedTest(name = "{displayName}.persister={0}") @ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER}) public void testAcknowledgementCommitCallbackCallsShareConsumerWakeup(String persister) throws InterruptedException { @@ -1349,7 +1343,6 @@ public void onComplete(Map> offsetsMap, Exception ex * Test to verify that the acknowledgement commit callback can throw an exception, and it is propagated * to the caller of poll(). */ - @Flaky("KAFKA-18033") @ParameterizedTest(name = "{displayName}.persister={0}") @ValueSource(strings = {NO_OP_PERSISTER, DEFAULT_STATE_PERSISTER}) public void testAcknowledgementCommitCallbackThrowsException(String persister) throws InterruptedException {