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

MINOR: Marking testVerifyFetchAndCloseImplicit flaky (#18893) 

Reviewers: Andrew Schofield <aschofield@confluent.io>, Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Apoorv Mittal 2025-02-13 20:57:06 +00:00 committed by GitHub
parent 3aae6f5402
commit e6b835f0b4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaShareConsumerTest.java
View File

@ -142,7 +142,7 @@ public class KafkaShareConsumerTest {
@Flaky("KAFKA-18488") @Flaky("KAFKA-18488")
@Test @Test
public void testVerifyFetchAndCommitSyncImplicit() throws InterruptedException { 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,
subscription, new LogContext(), new ClusterResourceListeners()); subscription, new LogContext(), new ClusterResourceListeners());
MockClient client = new MockClient(time, metadata); MockClient client = new MockClient(time, metadata);
@ -215,8 +215,9 @@ public class KafkaShareConsumerTest {
} }
} }
@Flaky("KAFKA-18794")
@Test @Test
public void testVerifyFetchAndCloseImplicit() throws InterruptedException { 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,
subscription, new LogContext(), new ClusterResourceListeners()); subscription, new LogContext(), new ClusterResourceListeners());
MockClient client = new MockClient(time, metadata); MockClient client = new MockClient(time, metadata);