kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yifan Ying <nafan...@gmail.com>
Subject InterruptedException when calling KafkaProducer.flush()
Date Thu, 11 May 2017 00:28:12 GMT
Hi Kafka users,

We are seeing some InterruptedException when calling KafkaProducer.flush().
The client version is 0.10.1.1. The error percentage is less than 1% and we
can't see any correlation with the volume of traffic. Here's the stacktrace,

org.apache.kafka.common.errors.InterruptException: Flush interrupted. at
org.apache.kafka.clients.producer.KafkaProducer.flush(KafkaProducer.java:619)
..... at com.netflix.hystrix.HystrixCommand$2.call(HystrixCommand.java:301)
at com.netflix.hystrix.HystrixCommand$2.call(HystrixCommand.java:297) at
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:46) at
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:35) at
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) at
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) at
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) at
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) at
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) at
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) at
rx.Observable.unsafeSubscribe(Observable.java:10151) at
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:51) at
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:35) at
rx.Observable.unsafeSubscribe(Observable.java:10151) at
rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)
at
rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)
at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) at
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) at
rx.Observable.unsafeSubscribe(Observable.java:10151) at
rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)
at
com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction$1.call(HystrixContexSchedulerAction.java:56)
at
com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction$1.call(HystrixContexSchedulerAction.java:47)
at
com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction.call(HystrixContexSchedulerAction.java:69)
at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55) at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at
java.util.concurrent.FutureTask.run(FutureTask.java:266) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745) Caused by:
java.lang.InterruptedException at
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:998)
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:57)
at
org.apache.kafka.clients.producer.internals.RecordAccumulator.awaitFlushCompletion(RecordAccumulator.java:477)
at
org.apache.kafka.clients.producer.KafkaProducer.flush(KafkaProducer.java:617)
... 35 more


We would like to know the cause of this issue and how to avoid it. Thanks!

-- 
Yifan

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message