You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2026/05/05 15:38:11 UTC
(kafka) branch trunk updated: KAFKA-15918: Fix flaky test OffsetsApiIntegrationTest.testResetSinkCo… (#21564)
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 <57...@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 <mi...@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());