>> if my application crash and i use pretty old offset(which are still within >> retention window), would kafka start from there ?
Yes. If you seek() to an old offset it will start from there. >> or does kafka still commit on every next poll, granted auto commit is off. if auto commit is off, the consumer will not commit on poll. -Matthias On 7/13/17 1:31 PM, Syed Rizwan Hashmi wrote: > Hi , > > I have wrote kafka consumer where i am managing kafka offset within our > storage. The reason why we are doing this, In case of failure we should be > able to restart from same time. > > I have disabled auto commit flag for offset. > > The writing of db happened that include offset write on interval base. That > means consumer continuously polling records but record might not commit in > db. My question here is .. > > if my application crash and i use pretty old offset(which are still within > retention window), would kafka start from there ? > > or does kafka still commit on every next poll, granted auto commit is off. > > kafka_2.11-0.10.1.1 > > -rIZ. >
signature.asc
Description: OpenPGP digital signature
