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 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

0.7.2 Async Producer Question

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