KAFKA-18794: Disable flaky tests pending investigation (#19340)

KafkaShareConsumerTest is proving very flaky. The behaviour of
MockClient does not appear to match the expectations of the test. This
PR disables the flaky tests to reduce build noise. When a proper
solution has been worked out, the tests can be re-enabled.

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Andrew Schofield 2025-04-01 16:52:06 +01:00 committed by GitHub
parent 1eea7f0528
commit cee55dbdec
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 3 deletions

View File

@ -45,11 +45,11 @@ import org.apache.kafka.common.requests.ShareGroupHeartbeatRequest;
import org.apache.kafka.common.requests.ShareGroupHeartbeatResponse; import org.apache.kafka.common.requests.ShareGroupHeartbeatResponse;
import org.apache.kafka.common.serialization.Deserializer; import org.apache.kafka.common.serialization.Deserializer;
import org.apache.kafka.common.serialization.StringDeserializer; import org.apache.kafka.common.serialization.StringDeserializer;
import org.apache.kafka.common.test.api.Flaky;
import org.apache.kafka.common.utils.LogContext; import org.apache.kafka.common.utils.LogContext;
import org.apache.kafka.common.utils.MockTime; import org.apache.kafka.common.utils.MockTime;
import org.apache.kafka.common.utils.Time; import org.apache.kafka.common.utils.Time;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.Timeout; import org.junit.jupiter.api.Timeout;
@ -140,7 +140,9 @@ public class KafkaShareConsumerTest {
} }
} }
@Flaky("KAFKA-18488") // This test is proving sufficiently flaky that it has been disabled pending investigation
@Disabled
// @Flaky("KAFKA-18488")
@Test @Test
public void testVerifyFetchAndCommitSyncImplicit() { public void testVerifyFetchAndCommitSyncImplicit() {
ConsumerMetadata metadata = new ConsumerMetadata(0, 0, Long.MAX_VALUE, false, false, ConsumerMetadata metadata = new ConsumerMetadata(0, 0, Long.MAX_VALUE, false, false,
@ -215,7 +217,9 @@ public class KafkaShareConsumerTest {
} }
} }
@Flaky("KAFKA-18794") // This test is proving sufficiently flaky that it has been disabled pending investigation
@Disabled
//@Flaky("KAFKA-18794")
@Test @Test
public void testVerifyFetchAndCloseImplicit() { public void testVerifyFetchAndCloseImplicit() {
ConsumerMetadata metadata = new ConsumerMetadata(0, 0, Long.MAX_VALUE, false, false, ConsumerMetadata metadata = new ConsumerMetadata(0, 0, Long.MAX_VALUE, false, false,