[KAFKA-12283] Flaky Test RebalanceSourceConnectorsIntegrationTest#testMultipleWorkersRejoining

• Type: Test
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 3.5.0
• Component/s: connect, unit tests
• Labels: flaky-test
• Assignee: Luke Chen
• Reporter: Matthias J. Sax
• Created: 03/Feb/21 18:02
• Updated: 20/Sep/23 04:22
• Resolved: 24/Jul/23 05:02

Description

https://github.com/apache/kafka/pull/10000/checks?check_run_id=1820092809

 {{java.lang.AssertionError: Tasks are imbalanced:
localhost:36037=[seq-source13-0, seq-source13-1, seq-source13-2, seq-source13-3, seq-source12-0, seq-source12-1, seq-source12-2, seq-source12-3]
localhost:43563=[seq-source11-0, seq-source11-2, seq-source10-0, seq-source10-2]
localhost:46539=[seq-source11-1, seq-source11-3, seq-source10-1, seq-source10-3]
at org.junit.Assert.fail(Assert.java:89)
at org.junit.Assert.assertTrue(Assert.java:42)
at org.apache.kafka.connect.integration.RebalanceSourceConnectorsIntegrationTest.assertConnectorAndTasksAreUniqueAndBalanced(RebalanceSourceConnectorsIntegrationTest.java:362)
at org.apache.kafka.test.TestUtils.lambda$waitForCondition$3(TestUtils.java:303)
at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:351)
at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:319)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:300)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:290)
at org.apache.kafka.connect.integration.RebalanceSourceConnectorsIntegrationTest.testMultipleWorkersRejoining(RebalanceSourceConnectorsIntegrationTest.java:313)}}

Issue Links

• is blocked by: KAFKA-12495 Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor
• links to: GitHub Pull Request #10054
• links to: GitHub Pull Request #10408