You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Ismael Juma (Jira)" <ji...@apache.org> on 2020/06/17 04:11:00 UTC
[jira] [Resolved] (KAFKA-8864) Kafka Producer deadlocked on flush
call
[ https://issues.apache.org/jira/browse/KAFKA-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma resolved KAFKA-8864.
--------------------------------
Resolution: Duplicate
Given the version, it looks like a duplicate of KAFKA-7709.
> Kafka Producer deadlocked on flush call
> ---------------------------------------
>
> Key: KAFKA-8864
> URL: https://issues.apache.org/jira/browse/KAFKA-8864
> Project: Kafka
> Issue Type: Bug
> Components: clients, producer
> Affects Versions: 2.1.0
> Reporter: Shaan Appel
> Priority: Major
>
> Some times the {{producer.flush}} call will be blocked by some lock. This may have been caused during a brief network outage.
> {code:java}
> "controlPort-19" #159 prio=6 os_prio=-1 tid=0x00007f8db0022800 nid=0xac waiting on condition [0x00007f8cb67e9000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00007f9f01812880> (a java.util.concurrent.CountDownLatch$Sync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
> at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231)
> at org.apache.kafka.clients.producer.internals.ProduceRequestResult.await(ProduceRequestResult.java:76)
> at org.apache.kafka.clients.producer.internals.RecordAccumulator.awaitFlushCompletion(RecordAccumulator.java:693)
> at org.apache.kafka.clients.producer.KafkaProducer.flush(KafkaProducer.java:1062)
> at com.datavisor.rtserver.messagebus.MBProducer.flush(MBProducer.java:85)
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)