Shaan Appel created KAFKA-8864:
----------------------------------
Summary: 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
Some times the {{producer.flush}} call will be blocked by some lock. This may
have been caused during a brief network outage.
"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)
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
