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)
