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.
