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 <jinxing6...@126.com> wrote: > if i wanna send the message syncronously i can do as below: > future=producer.send(producerRecord, callback); > future.get(); > > > but the throughput decrease dramatically; > > > is there a method to send the messages by batch but synchronously ? > >
