Skip to content

Commit 7da1a6c

Browse files
authored
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 <[email protected]>, Apoorv Mittal <[email protected]>, Andrew Schofield <[email protected]>
1 parent c56c9fa commit 7da1a6c

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

Diff for: core/src/test/java/kafka/test/api/ShareConsumerTest.java

-4
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,6 @@
6161
import org.apache.kafka.common.test.api.ClusterConfigProperty;
6262
import org.apache.kafka.common.test.api.ClusterTest;
6363
import org.apache.kafka.common.test.api.ClusterTestDefaults;
64-
import org.apache.kafka.common.test.api.Flaky;
6564
import org.apache.kafka.common.test.api.Type;
6665
import org.apache.kafka.common.utils.Utils;
6766
import org.apache.kafka.coordinator.group.GroupConfig;
@@ -390,7 +389,6 @@ public void testAcknowledgementCommitCallbackOnClose() {
390389
}
391390
}
392391

393-
@Flaky("KAFKA-18033")
394392
@ClusterTest
395393
public void testAcknowledgementCommitCallbackInvalidRecordStateException() throws Exception {
396394
setup();
@@ -1079,7 +1077,6 @@ public void testMultipleConsumersInGroupSequentialConsumption() {
10791077
}
10801078
}
10811079

1082-
@Flaky("KAFKA-18033")
10831080
@ClusterTest
10841081
public void testMultipleConsumersInGroupConcurrentConsumption()
10851082
throws InterruptedException, ExecutionException, TimeoutException {
@@ -2027,7 +2024,6 @@ public void testShareConsumerAfterCoordinatorMovement() throws Exception {
20272024
}
20282025
)
20292026
@Timeout(150)
2030-
@Flaky("KAFKA-18665")
20312027
public void testComplexShareConsumer() throws Exception {
20322028
setup();
20332029
String topicName = "multipart";

0 commit comments

Comments
 (0)