[KAFKA-9597] Flaky Test KafkaProducerTest#testInitTransactionTimeout

• Type: Bug
• Status: Open
• Priority: Critical
• Resolution: Unresolved
• Component/s: clients, producer , unit tests
• Labels: flaky-test
• Assignee: Unassigned
• Reporter: Matthias J. Sax
• Created: 23/Feb/20 12:23
• Updated: 01/Aug/23 23:47

Description

https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4866/testReport/junit/org.apache.kafka.clients.producer/KafkaProducerTest/testInitTransactionTimeout/

java.lang.IllegalStateException: No requests pending for inbound response FindCoordinatorResponseData(throttleTimeMs=0, errorCode=0, errorMessage='NONE', nodeId=0, host='host1', port=1000) at org.apache.kafka.clients.MockClient.respond(MockClient.java:345) at org.apache.kafka.clients.MockClient.respond(MockClient.java:319) at org.apache.kafka.clients.producer.KafkaProducerTest.testInitTransactionTimeout(KafkaProducerTest.java:770)

STDOUT:

[2020-02-22 08:52:04,203] ERROR [Producer clientId=producer-9] Uncaught error in kafka producer I/O thread: (org.apache.kafka.clients.producer.internals.Sender:241) java.lang.IllegalStateException: No previous metadata update to use at org.apache.kafka.clients.MockClient$DefaultMockMetadataUpdater.updateWithCurrentMetadata(MockClient.java:623) at org.apache.kafka.clients.MockClient.poll(MockClient.java:287) at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:324) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:239) at java.base/java.lang.Thread.run(Thread.java:834) [2020-02-22 08:52:04,863] ERROR [Producer clientId=producer-10] Interrupted while joining ioThread (org.apache.kafka.clients.producer.KafkaProducer:1197) java.lang.InterruptedException at java.base/java.lang.Object.wait(Native Method) at java.base/java.lang.Thread.join(Thread.java:1313) at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1194) at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1171) at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1147) at org.apache.kafka.clients.producer.KafkaProducerTest.lambda$shouldCloseProperlyAndThrowIfInterrupted$1(KafkaProducerTest.java:295) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) [2020-02-22 08:52:05,343] ERROR Metadata response reported invalid topics [topic abc] (org.apache.kafka.clients.Metadata:295)