I added a comment/suggestion to:https://issues.apache.org/jira/browse/KAFKA-966
Basically to expose an api for marking an offset for commit, such that the
auto-commit would only commit offsets up to the last message
'markedForCommit', and not the last 'consumed' offset, which may or may not
have succeeded. This way, consumer code can just call 'markForCommit()'
after successfully processing each message successfully.
Does that make sense?
On Mon, Sep 9, 2013 at 5:21 PM, Yu, Libo <[EMAIL PROTECTED]> wrote: