[KAFKA-14453] Flaky test suite MirrorConnectorsWithCustomForwardingAdminIntegrationTest

• Type: Test
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: mirrormaker
• Labels: flaky-test
• Assignee: Unassigned
• Reporter: Chris Egerton
• Created: 07/Dec/22 21:57
• Updated: 6 days ago 06:59

Description

We've been seeing some integration test failures lately for the MirrorConnectorsWithCustomForwardingAdminIntegrationTest test suite. A couple examples:

org.opentest4j.AssertionFailedError: Condition not met within timeout 60000. Topic: mm2-offset-syncs.backup.internal didn't get created in the FakeLocalMetadataStore ==> expected: <true> but was: <false>
    at app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
    at app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
    at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
    at app//org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36)
    at app//org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:210)
    at app//org.apache.kafka.test.TestUtils.lambda$waitForCondition$4(TestUtils.java:337)
    at app//org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
    at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:334)
    at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:318)
    at app//org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:308)
    at app//org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.waitForTopicToPersistInFakeLocalMetadataStore(MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java:326)
    at app//org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testReplicationIsCreatingTopicsUsingProvidedForwardingAdmin(MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java:217)
{{}}

 

And:

 

org.opentest4j.AssertionFailedError: Condition not met within timeout 60000. Topic: primary.test-topic-1's configs don't have partitions:11 ==> expected: <true> but was: <false>
    }}{{at org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
    }}{{at org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
    }}{{at org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)
    }}{{at org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36)
    }}{{at org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:210)
    }}{{at org.apache.kafka.test.TestUtils.lambda$waitForCondition$4(TestUtils.java:337)
    }}{{at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
    }}{{at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:334)
    }}{{at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:318)
    }}{{at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:308)
    }}{{at org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.waitForTopicConfigPersistInFakeLocalMetaDataStore(MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java:334)
    }}{{at org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegrationTest.testCreatePartitionsUseProvidedForwardingAdmin(MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java:255)