Re: async producer callback not reliable

2015-09-09 Thread Mayuresh Gharat
Make sure you have inflight requests set to 1 if you want ordered messages. Thanks, Mayuresh On Tue, Sep 8, 2015 at 5:55 AM, Damian Guy wrote: > Can you do: > producer.send(...) > ... > producer.send(...) > producer.flush() > > By the time the flush returns all of your messages should have bee

Re: async producer callback not reliable

2015-09-08 Thread Damian Guy
Can you do: producer.send(...) ... producer.send(...) producer.flush() By the time the flush returns all of your messages should have been sent On 8 September 2015 at 11:50, jinxing wrote: > if i wanna send the message syncronously i can do as below: > future=producer.send(producerRecord, callb