root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-18033: Remove flaky tag in ShareConsumerTest (#18995) 

3 tests which were marked flaky in ShareConsumerTest do not have any
failure on trunk since the test was converted to use `ClusterTestExtensions`.

Reviewers: Sushant Mahajan <smahajan@confluent.io>, Apoorv Mittal <apoorvmittal10@gmail.com>, Andrew Schofield <aschofield@confluent.io>
This commit is contained in:
Shivsundar R 2025-02-21 08:50:08 -05:00 committed by GitHub
parent c56c9faee2
commit 7da1a6cbff
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/test/java/kafka/test/api/ShareConsumerTest.java
View File

@ -61,7 +61,6 @@ import org.apache.kafka.common.test.ClusterInstance;
import org.apache.kafka.common.test.api.ClusterConfigProperty; import org.apache.kafka.common.test.api.ClusterConfigProperty;
import org.apache.kafka.common.test.api.ClusterTest; import org.apache.kafka.common.test.api.ClusterTest;
import org.apache.kafka.common.test.api.ClusterTestDefaults; import org.apache.kafka.common.test.api.ClusterTestDefaults;
import org.apache.kafka.common.test.api.Flaky;
import org.apache.kafka.common.test.api.Type; import org.apache.kafka.common.test.api.Type;
import org.apache.kafka.common.utils.Utils; import org.apache.kafka.common.utils.Utils;
import org.apache.kafka.coordinator.group.GroupConfig; import org.apache.kafka.coordinator.group.GroupConfig;
@ -390,7 +389,6 @@ public class ShareConsumerTest {
} }
} }
@Flaky("KAFKA-18033")
@ClusterTest @ClusterTest
public void testAcknowledgementCommitCallbackInvalidRecordStateException() throws Exception { public void testAcknowledgementCommitCallbackInvalidRecordStateException() throws Exception {
setup(); setup();
@ -1079,7 +1077,6 @@ public class ShareConsumerTest {
} }
} }
@Flaky("KAFKA-18033")
@ClusterTest @ClusterTest
public void testMultipleConsumersInGroupConcurrentConsumption() public void testMultipleConsumersInGroupConcurrentConsumption()
throws InterruptedException, ExecutionException, TimeoutException { throws InterruptedException, ExecutionException, TimeoutException {
@ -2027,7 +2024,6 @@ public class ShareConsumerTest {
} }
) )
@Timeout(150) @Timeout(150)
@Flaky("KAFKA-18665")
public void testComplexShareConsumer() throws Exception { public void testComplexShareConsumer() throws Exception {
setup(); setup();
String topicName = "multipart"; String topicName = "multipart";