[
https://issues.apache.org/jira/browse/KAFKA-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18128050#comment-18128050
]
CHIA MIN LIU commented on KAFKA-9597:
-------------------------------------
{{*KafkaProducerTest.testInitTransactionTimeout()*}} is still showing
intermittent failures on trunk. The recent failure differs from the original
{{*_No requests pending_*}} error reported here:
{code:java}
org.apache.kafka.common.errors.TimeoutException:
Timeout expired after 500ms while awaiting InitProducerId.
InitTransactions timed out - did not complete coordinator discovery
or receive the InitProducerId response within max.block.ms. {code}
h4. Recent examples, with execution times in UTC:
* [2026-10-16
17:20:43|https://develocity.apache.org/s/y6tb66ul3fzoi/tests/task/:clients:test/details/org.apache.kafka.clients.producer.KafkaProducerTest/testInitTransactionTimeout%28%29]:
failed in 1.350s, retry passed in 0.698s.
* [2026-10-14
12:26:30|https://develocity.apache.org/s/bjfpuioctbtoa/tests/task/:clients:test/details/org.apache.kafka.clients.producer.KafkaProducerTest/testInitTransactionTimeout%28%29]:
failed in 1.146s, retry passed in 0.774s.
> Flaky Test KafkaProducerTest#testInitTransactionTimeout
> -------------------------------------------------------
>
> Key: KAFKA-9597
> URL: https://issues.apache.org/jira/browse/KAFKA-9597
> Project: Kafka
> Issue Type: Bug
> Components: clients, producer , unit tests
> Reporter: Matthias J. Sax
> Assignee: CHIA MIN LIU
> Priority: Critical
> Labels: flaky-test
>
> [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.20.10#820010)
