essentially i want to use this property "queue.buffering.max.messages" with new KafkaProducer class, and also want to access the current value of the queue
SunilKalva On Wed, Mar 18, 2015 at 9:51 PM, sunil kalva <sambarc...@gmail.com> wrote: > > Hi > How do i get the size of the inmemory queue which are holding messages and > ready to send in async producer, i am using new KafkaProducer class in > 0.8.2. > > Basically instead of dropping the messages silently, i want to avoid > sending messages if the queue is already full. I am using async > KafkaProdcuer class. > > Or is there anyother better way to handle this, since i am using async > client i can not catch the exception i think. > > -- > SunilKalva > -- SunilKalva
