By default producer batches records (into a buffer) until batch.size is reached, then records will be sent out. Try lowering batch.size in your producer config.
You might want to look at the producer javadoc here: http://kafka.apache.org/0102/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html On Wed, Mar 1, 2017 at 3:14 AM, Yuanjia <yuanjia8...@163.com> wrote: > Hi all, > When will the messsages be sent in kafka0.10.0?If I use KafkaProducer.send > to send one message, the messsages isn't sent immediately except invoke > flush or close. > > Thanks. > > > > Yuanjia Li > -- Kaufman Ng +1 646 961 8063 Solutions Architect | Confluent | www.confluent.io
