Matthias J. Sax created KAFKA-12567:
---------------------------------------
Summary: Flaky Test TransactionsTest.testFencingOnCommit
Key: KAFKA-12567
URL: https://issues.apache.org/jira/browse/KAFKA-12567
Project: Kafka
Issue Type: Test
Components: core, unit tests
Reporter: Matthias J. Sax
{quote}org.opentest4j.AssertionFailedError: Consumed 0 records before timeout
instead of the expected 2 records at
org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:39) at
org.junit.jupiter.api.Assertions.fail(Assertions.java:117) at
kafka.utils.TestUtils$.pollUntilAtLeastNumRecords(TestUtils.scala:852) at
kafka.utils.TestUtils$.consumeRecords(TestUtils.scala:1476) at
kafka.api.TransactionsTest.testFencingOnCommit(TransactionsTest.scala:331){quote}
STDOUT (all of those line appear multiple times throwout the test)
{quote}[2021-03-24 18:29:44,013] ERROR [ZooKeeperClient] Auth failed.
(kafka.zookeeper.ZooKeeperClient:74)
...
[2021-03-24 18:29:46,251] WARN [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Received UNKNOWN_TOPIC_OR_PARTITION from the leader for partition
topic2-0. This error may be returned transiently when the partition is being
created or deleted, but it is not expected to persist.
(kafka.server.ReplicaFetcherThread:70)
...
[2021-03-24 18:29:46,326] WARN Error registering AppInfo mbean
(org.apache.kafka.common.utils.AppInfoParser:68)
javax.management.InstanceAlreadyExistsException:
kafka.producer:type=app-info,id=producer-transactional-producer at
com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437) at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at
com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at
org.apache.kafka.common.utils.AppInfoParser.registerAppInfo(AppInfoParser.java:64)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:434)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:291)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:318)
at kafka.utils.TestUtils$.createTransactionalProducer(TestUtils.scala:1518) at
kafka.api.TransactionsTest.createTransactionalProducer(TransactionsTest.scala:775)
at kafka.api.TransactionsTest.$anonfun$setUp$1(TransactionsTest.scala:69) at
kafka.api.TransactionsTest.$anonfun$setUp$1$adapted(TransactionsTest.scala:68)
at scala.collection.immutable.Range.foreach(Range.scala:190) at
kafka.api.TransactionsTest.setUp(TransactionsTest.scala:68)
...
[2021-03-24 18:29:46,810] WARN [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error in response for fetch request (type=FetchRequest,
replicaId=1, maxWait=500, minBytes=1, maxBytes=10485760,
fetchData=\{topic2-3=PartitionData(fetchOffset=0, logStartOffset=0,
maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty), topic2-0=PartitionData(fetchOffset=0,
logStartOffset=0, maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty),
__transaction_state-1=PartitionData(fetchOffset=0, logStartOffset=0,
maxBytes=1048576, currentLeaderEpoch=Optional[0],
lastFetchedEpoch=Optional.empty)}, isolationLevel=READ_UNCOMMITTED, toForget=,
metadata=(sessionId=1510423728, epoch=1), rackId=)
(kafka.server.ReplicaFetcherThread:72) java.io.IOException: Connection to 0 was
disconnected before the response was read at
org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100)
at
kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:110)
at
kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:217)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:313)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:137)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:136)
at scala.Option.foreach(Option.scala:437) at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:136)
at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:119)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96){quote}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
