kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Cheolwoo Choi <pror...@gmail.com>
Subject How to commit offset every time, automatically
Date Mon, 28 Oct 2013 00:49:50 GMT
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 ?


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message