This exception typically means that the client is sending messages at a rate faster than the broker can handle. Check if flush interval is set properly at the broker. Is this trunk or 0.7.0?
Thanks, Jun On Tue, Jun 12, 2012 at 5:14 PM, xiaoyu wang <xiaoyu.w...@gmail.com> wrote: > 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 >
