Hi, all
I'm using kafka-0.7.2

I'd like to commit offset every time reading a message block.
"autocommit.interval.ms" property is not enough.

To do that, should I use SimpleConsumer, and write a commit logic manually?
(i.e. zkUtils.commitOffset(groupId, messageAndOffset.offset() )

Is there no way to commit automatically every time ?

Thanks

Reply via email to