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
