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
