[ https://issues.apache.org/jira/browse/KAFKA-12566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17323975#comment-17323975 ]
Matthias J. Sax commented on KAFKA-12566: ----------------------------------------- Another one for {{testReplicationWithEmptyPartition()}} [https://github.com/apache/kafka/pull/10548/checks?check_run_id=2363332696] > Flaky Test MirrorConnectorsIntegrationSSLTest#testReplication > ------------------------------------------------------------- > > Key: KAFKA-12566 > URL: https://issues.apache.org/jira/browse/KAFKA-12566 > Project: Kafka > Issue Type: Test > Components: mirrormaker, unit tests > Reporter: Matthias J. Sax > Assignee: Luke Chen > Priority: Critical > Labels: flaky-test > > > {code:java} > org.opentest4j.AssertionFailedError: Condition not met within timeout 20000. > Offsets not translated downstream to primary cluster. ==> expected: <true> > but was: <false> at > org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:55) at > org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:40) at > org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:193) 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.mirror.integration.MirrorConnectorsIntegrationBaseTest.testReplication(MirrorConnectorsIntegrationBaseTest.java:289) > {code} > {{LOGs}} > {quote}[2021-03-26 03:28:06,157] ERROR Could not check connector state info. > (org.apache.kafka.connect.util.clusters.EmbeddedConnectClusterAssertions:420) > org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Could not > read connector state. Error response: \{"error_code":404,"message":"No status > found for connector MirrorSourceConnector"} at > org.apache.kafka.connect.util.clusters.EmbeddedConnectCluster.connectorStatus(EmbeddedConnectCluster.java:479) > at > org.apache.kafka.connect.util.clusters.EmbeddedConnectClusterAssertions.checkConnectorState(EmbeddedConnectClusterAssertions.java:413) > at > org.apache.kafka.connect.util.clusters.EmbeddedConnectClusterAssertions.lambda$assertConnectorAndAtLeastNumTasksAreRunning$16(EmbeddedConnectClusterAssertions.java:286) > 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.util.clusters.EmbeddedConnectClusterAssertions.assertConnectorAndAtLeastNumTasksAreRunning(EmbeddedConnectClusterAssertions.java:285) > at > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.waitUntilMirrorMakerIsRunning(MirrorConnectorsIntegrationBaseTest.java:470) > at > org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.testReplication(MirrorConnectorsIntegrationBaseTest.java:227){quote} > and > {quote}[2021-03-26 03:30:41,524] ERROR [MirrorHeartbeatConnector|task-0] > Graceful stop of task MirrorHeartbeatConnector-0 failed. > (org.apache.kafka.connect.runtime.Worker:866) [2021-03-26 03:30:41,527] ERROR > [MirrorHeartbeatConnector|task-0] > WorkerSourceTask\{id=MirrorHeartbeatConnector-0} failed to send record to > heartbeats: (org.apache.kafka.connect.runtime.WorkerSourceTask:372) > org.apache.kafka.common.KafkaException: Producer is closed forcefully. at > org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches(RecordAccumulator.java:750) > at > org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches(RecordAccumulator.java:737) > at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:282) > at java.lang.Thread.run(Thread.java:748) [2021-03-26 03:30:42,248] ERROR > [MirrorHeartbeatConnector|task-0] > WorkerSourceTask\{id=MirrorHeartbeatConnector-0} Failed to flush, timed out > while waiting for producer to flush outstanding 1 messages > (org.apache.kafka.connect.runtime.WorkerSourceTask:512){quote} > -- This message was sent by Atlassian Jira (v8.3.4#803005)