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

Reply via email to