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
