(kafka) branch trunk updated: KAFKA-15918: Fix flaky test OffsetsApiIntegrationTest.testResetSinkCo… (#21564)

[mimaison]

This is an automated email from the ASF dual-hosted git repository.

mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 9c106dc9d01 KAFKA-15918: Fix flaky test 
OffsetsApiIntegrationTest.testResetSinkCo… (#21564)
9c106dc9d01 is described below

commit 9c106dc9d01b778b4aa4e7b810996880db1f24c3
Author: Shekhar Prasad Rajak <5774448+shekharra...@users.noreply.github.com>
AuthorDate: Tue May 5 21:08:02 2026 +0530

    KAFKA-15918: Fix flaky test OffsetsApiIntegrationTest.testResetSinkCo… 
(#21564)
    
    After connector tasks are reported as RUNNING, there's still a delay
    before:  Consumer group fully forms  Partitions get assigned  Records
    are consumed  Offsets are committed
    
    The 30-second timeout (OFFSET_READ_TIMEOUT_MS) is insufficient in slow
    CI environments
    
    Reviewers: Mickael Maison <mickael.mai...@gmail.com>
---
 .../apache/kafka/connect/integration/OffsetsApiIntegrationTest.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java
 
b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java
index c9edd6093bd..0ce7ecd5a5b 100644
--- 
a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java
+++ 
b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java
@@ -81,8 +81,8 @@ public class OffsetsApiIntegrationTest {
 
     private static final Logger log = 
LoggerFactory.getLogger(OffsetsApiIntegrationTest.class);
 
-    private static final long OFFSET_COMMIT_INTERVAL_MS = 
TimeUnit.SECONDS.toMillis(1);
-    private static final long OFFSET_READ_TIMEOUT_MS = 
TimeUnit.SECONDS.toMillis(30);
+    private static final long OFFSET_COMMIT_INTERVAL_MS = 500L;
+    private static final long OFFSET_READ_TIMEOUT_MS = 
TimeUnit.SECONDS.toMillis(60);
     private static final int NUM_WORKERS = 3;
     private static final int NUM_TASKS = 2;
     private static final int NUM_RECORDS_PER_PARTITION = 10;
@@ -703,7 +703,6 @@ public class OffsetsApiIntegrationTest {
         }
     }
 
-    @Flaky("KAFKA-15918")
     @Test
     public void testResetSinkConnectorOffsets() throws Exception {
         resetAndVerifySinkConnectorOffsets(baseSinkConnectorConfigs(), 
connect.kafka());