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