kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Damian Guy <damian....@gmail.com>
Subject Re: async producer callback not reliable
Date Tue, 08 Sep 2015 12:55:39 GMT
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 <jinxing6042@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 ?
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message