Thanks. This is 0.7.0. On Wed, Jun 13, 2012 at 7:52 AM, Jun Rao <jun...@gmail.com> wrote:
> 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 > > >
