Take a look here: https://issues.apache.org/jira/browse/KAFKA-1865
On Wed, Mar 4, 2015 at 4:28 AM, Ponmani Rayar <ymmu...@gmail.com> wrote: > Hi Group, > > I have started using Kafka 0.8.2 with the new producer API. > Just wanted to know if we can have an explicit control over flushing the > messages batch to Kafka cluster. > > Configuring batch.size will flush the messages when the batch.size is > reached for a partition. > But is there any API where in i can have a explicit control of flushing the > messages, something like > > *kafkaProducer.flush(); * > > Please let me know if there is any API or specific configuration to do > this. > > Thanks in advance, > Ponmani > -- Jeff Holoman Systems Engineer
