Hi all,

I am streaming my logs to kakfa using javaapi. The producer type is
configured "async". I started seeing exceptions after starting my server
for a few minutes

"kafka.producer.async.AsyncProducer - event queue is full of unsent
messages, cannot send event: 59..." But when I look at jmx stats, the
AsyncProducerQueueSize and AsyncProducerDroppedEvents are always 0.

any idea why this is happening?

Thanks,

-Xiaoyu

Reply via email to