Sunil,
Batching is performed for you automatically. There are a few settings you
can use to tweak it's behavior (e.g. linger.ms and batch.size), but the
defaults are good for common workloads and can achieve very high throughput.
If you want to send some messages and then wait for them to be acknowledged
before continuing, you can use the futures that are returned by
producer.send(). Just send many messages, then wait for all the futures by
calling get() on them.
The code on the trunk branch also has a flush() method which does the same
thing without you having to collect all the futures. However, that wasn't
added until after 0.8.2.1 was released. It'll be available with 0.8.3 and
simplifies this use case a bit.
-Ewen
On Sat, Aug 1, 2015 at 1:40 AM, sunil kalva sambarc...@gmail.com wrote:
Can i configure new producer api with batch, and send data in batches in
synchronous mode ?
--
SunilKalva
--
Thanks,
Ewen
