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:
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB