The 0.7.2 producer should already do that on a clean shutdown of the producer.
On Tue, Nov 5, 2013 at 9:09 AM, Sriram Ramarathnam <rsrira...@gmail.com>wrote: > I am using kafka 0.7.2. I want to make sure that the producer queue is > flushed before I can call a close on the producer. Is there a way to > achieve this? > > Thanks, > Sriram >
