[KAFKA-14718] Flaky DedicatedMirrorIntegrationTest test suite

• Type: Test
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.6.0, 3.5.1
• Component/s: mirrormaker
• Labels: flaky-test
• Assignee: Divij Vaidya
• Reporter: Chris Egerton
• Created: 14/Feb/23 21:34
• Updated: 11/Jul/23 09:12
• Resolved: 10/Jul/23 16:54

Description

These tests were added recently in https://github.com/apache/kafka/pull/13137 and have been failing occasionally on Jenkins. For example, in https://github.com/apache/kafka/pull/13163, both test cases (testSingleNodeCluster and testMultiNodeCluster) failed on a single Jenkins node with timeout errors:

[2023-02-14T16:43:19.054Z] Gradle Test Run :connect:mirror:integrationTest > Gradle Test Executor 155 > DedicatedMirrorIntegrationTest > testSingleNodeCluster() FAILED [2023-02-14T16:43:19.054Z] org.opentest4j.AssertionFailedError: Condition not met within timeout 30000. topic A.test-topic-1 was not created on cluster B in time ==> expected: <true> but was: <false> [2023-02-14T16:43:19.054Z] at org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151) [2023-02-14T16:43:19.054Z] at org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132) [2023-02-14T16:43:19.054Z] at org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63) [2023-02-14T16:43:19.054Z] at org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36) [2023-02-14T16:43:19.054Z] at org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:211) [2023-02-14T16:43:19.054Z] at org.apache.kafka.test.TestUtils.lambda$waitForCondition$4(TestUtils.java:337) [2023-02-14T16:43:19.054Z] at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385) [2023-02-14T16:43:19.054Z] at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:334) [2023-02-14T16:43:19.054Z] at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:318) [2023-02-14T16:43:19.054Z] at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:308) [2023-02-14T16:43:19.054Z] at org.apache.kafka.connect.mirror.integration.DedicatedMirrorIntegrationTest.awaitTopicCreation(DedicatedMirrorIntegrationTest.java:255) [2023-02-14T16:43:19.054Z] at org.apache.kafka.connect.mirror.integration.DedicatedMirrorIntegrationTest.testSingleNodeCluster(DedicatedMirrorIntegrationTest.java:153)

Issue Links

• is caused by: KAFKA-15059 Exactly-once source tasks fail to start during pending rebalances
• links to: GitHub Pull Request #13284
• links to: GitHub Pull Request #13819