You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Oleg Muravskiy (Jira)" <ji...@apache.org> on 2022/05/20 10:14:00 UTC
[jira] [Updated] (KAFKA-13920) KafkaProducer.close waits idefinitely on ioThread that is not joining
[ https://issues.apache.org/jira/browse/KAFKA-13920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Oleg Muravskiy updated KAFKA-13920:
-----------------------------------
Affects Version/s: 2.8.0
(was: 2.6.2)
> KafkaProducer.close waits idefinitely on ioThread that is not joining
> ----------------------------------------------------------------------
>
> Key: KAFKA-13920
> URL: https://issues.apache.org/jira/browse/KAFKA-13920
> Project: Kafka
> Issue Type: Bug
> Components: producer
> Affects Versions: 2.8.0
> Reporter: Oleg Muravskiy
> Priority: Major
>
> {{When closing (transactional) KafkaProducer, it keeps waiting for the ioThread to join:}}
> {{}}
> {code:java}
> "MainLoop" #24 prio=5 os_prio=0 tid=0x00007f93d8afb800 nid=0x2c398 in Object.wait() [0x00007f93a0cf8000]
> java.lang.Thread.State: TIMED_WAITING (on object monitor)
> at java.lang.Object.wait(Native Method)
> at java.lang.Thread.join(Thread.java:1265)
> - locked <0x0000000085feb2c0> (a org.apache.kafka.common.utils.KafkaThread)
> at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1220)
> at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1197)
> at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1173){code}
> {{while the ioThread is in this state:}}
> {{}}
> {code:java}
> "kafka-producer-network-thread | produce-ris-live-consume1.vega" #26 daemon prio=5 os_prio=0 tid=0x00007f92d01e1800 nid=0x2c399 waiting on condition [0x00007f93a03ca000]
> java.lang.Thread.State: TIMED_WAITING (sleeping)
> at java.lang.Thread.sleep(Native Method)
> at org.apache.kafka.common.utils.Utils.sleep(Utils.java:375)
> at org.apache.kafka.common.utils.SystemTime.sleep(SystemTime.java:41)
> at org.apache.kafka.clients.producer.internals.Sender.maybeSendAndPollTransactionalRequest(Sender.java:463)
> at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:315)
> at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:255)
> at java.lang.Thread.run(Thread.java:750){code}
> {{and does not quit.}}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)