Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> 0.7.2 Async Producer Question


Copy link to this message
-
Re: 0.7.2 Async Producer Question
Yes, that's the right way to block on queue full.

Thanks,

Jun
On Sun, Apr 28, 2013 at 12:30 PM, Suyog Rao <[EMAIL PROTECTED]> wrote:

> Hi, in Kafka 0.7.2 we are getting QueueFullExceptions while using the
> AsyncProducer with queue.size = 50K and 1 producer. I read that we can make
> this internal queue blocking by setting queue.enqueue.timeout.ms = -1. Is
> that possible in 0.7.2? On the broker side, the log.flush.interval is set
> to 10K
>
> Thanks,
> Suyog

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB