incubator-kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joel Koshy <jjkosh...@gmail.com>
Subject Re: producer queue size
Date Tue, 27 Nov 2012 00:06:36 GMT
To use async, set producer.type to async ; The default queue size is 10000;
and the default batch size is 200.


On Mon, Nov 26, 2012 at 2:28 PM, Jamie Wang <jamie.wang@actuate.com> wrote:

> Hi, I am running the console demo comes with 0.7.2  in getting started
> guide. All is working fine. Then I use stdio redirect a file of 30K lines
> of messages into the producer and I received  an error "ERROR Event queue
> is full of unsent messages, could not send event:..." and exception stack
> shows:
> Exception in thread "main" kafka.producer.async.QueueFullException: Event
> queue is full of unsent messages, could not send event:...
>
> Is there a way in the produce.properties to configure the size of producer
> queue?   I know the producer is running in synchronous mode. How do I solve
> this problem or my usage is totally wrong?
>
> Thanks
> Jamie
>

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