[ https://issues.apache.org/jira/browse/KAFKA-16655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842820#comment-17842820 ]
Alyssa Huang commented on KAFKA-16655: -------------------------------------- [https://github.com/apache/kafka/pull/15845/files] > deflake ZKMigrationIntegrationTest.testDualWrite > ------------------------------------------------ > > Key: KAFKA-16655 > URL: https://issues.apache.org/jira/browse/KAFKA-16655 > Project: Kafka > Issue Type: Improvement > Reporter: Alyssa Huang > Assignee: Alyssa Huang > Priority: Minor > > {code:java} > Failed to map supported failure 'org.opentest4j.AssertionFailedError: > expected: not equal but was: <0>' with mapper > 'org.gradle.api.internal.tasks.testing.failure.mappers.OpenTestAssertionFailedMapper@59b5251d': > Cannot invoke "Object.getClass()" because "obj" is null > > Task :core:test > kafka.zk.ZkMigrationIntegrationTest.testDualWrite(ClusterInstance)[8] failed, > log available in > /Users/ahuang/ce-kafka/core/build/reports/testOutput/kafka.zk.ZkMigrationIntegrationTest.testDualWrite(ClusterInstance)[8].test.stdout > Gradle Test Run :core:test > Gradle Test Executor 8 > > ZkMigrationIntegrationTest > testDualWrite(ClusterInstance) > testDualWrite > [8] Type=ZK, MetadataVersion=3.8-IV0, Security=PLAINTEXT FAILED > org.opentest4j.AssertionFailedError: expected: not equal but was: <0> > at > app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:152) > at > app//org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132) > at > app//org.junit.jupiter.api.AssertNotEquals.failEqual(AssertNotEquals.java:277) > at > app//org.junit.jupiter.api.AssertNotEquals.assertNotEquals(AssertNotEquals.java:119) > at > app//org.junit.jupiter.api.AssertNotEquals.assertNotEquals(AssertNotEquals.java:111) > at > app//org.junit.jupiter.api.Assertions.assertNotEquals(Assertions.java:2121) > at > app//kafka.zk.ZkMigrationIntegrationTest.testDualWrite(ZkMigrationIntegrationTest.scala:995) > {code} > This test occasionally fails due to stale broker epoch exceptions, which in > turn causes allocate producer ids to fail. > Also fixes {{sendAllocateProducerIds}} erroneously returning 0 as the > `producerIdStart` in error cases (because `onComplete` only accounts for > timeouts and ignores any other error code) > {code:java} > [2024-04-12 18:45:08,820] INFO [ControllerServer id=3000] > allocateProducerIds: event failed with StaleBrokerEpochException in 19 > microseconds. (org.apache.kafka.controller.QuorumController:765) {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)