Also if you are using Kafka from the latest trunk, KafkaProducer has a flush() interface that you may call. This will ensure all the message previously sent from send() methods are sent to Kafka server.
On 4/3/15, 3:38 PM, "Sun, Joey" <[email protected]> wrote: >Hello, group > >I am a newbie to Kafka. I am researching on how to commit a new appended >log message (e.g. apache access log) to Kafka. Could you please share >some ideas/solutions? > >Thanks >Liang
