[jira] [Created] (KAFKA-9597) Flaky Test KafkaProducerTest#testInitTransactionTimeout

["Matthias J. Sax (Jira)" <ji...@apache.org>]

Matthias J. Sax created KAFKA-9597:
--------------------------------------

             Summary: Flaky Test KafkaProducerTest#testInitTransactionTimeout
                 Key: KAFKA-9597
                 URL: https://issues.apache.org/jira/browse/KAFKA-9597
             Project: Kafka
          Issue Type: Bug
          Components: producer , unit tests
            Reporter: Matthias J. Sax


[https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4866/testReport/junit/org.apache.kafka.clients.producer/KafkaProducerTest/testInitTransactionTimeout/]
{quote}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){quote}
STDOUT:
{quote}[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){quote}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)