Re: Flush producer queue

2013-11-05 Thread Neha Narkhede
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 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?

Flush producer queue

2013-11-05 Thread Sriram Ramarathnam
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