[ https://issues.apache.org/jira/browse/KAFKA-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14280619#comment-14280619 ]
Joel Koshy commented on KAFKA-1870: ----------------------------------- Committing offsets to Kafka is a little more complicated - i.e., you need to discover the offset manager for your group and then send the request to that broker. https://cwiki.apache.org/confluence/display/KAFKA/Committing+and+fetching+consumer+offsets+in+Kafka I think the SimpleConsumer should only send v0 of OffsetCommitRequest. For people who wish to commit offsets manually to ZooKeeper they will need to do so explicitly (via a BlockingChannel) or until we get KAFKA-1013 in. > Cannot commit with simpleConsumer on Zookeeper only with Java API > ----------------------------------------------------------------- > > Key: KAFKA-1870 > URL: https://issues.apache.org/jira/browse/KAFKA-1870 > Project: Kafka > Issue Type: Bug > Components: consumer > Affects Versions: 0.8.2 > Reporter: Thomas Vandevelde > Priority: Minor > Attachments: OffsetCommitRequest.diff > > Original Estimate: 1h > Remaining Estimate: 1h > > From Kafka 0.8.2, we need to pass version 0 in the OffsetCommitRequest if we > want to commit only on zookeeper. > However the Java API doesnt allow to pass the version in parameter. > Can you please add the version in the constructor of > kafka.javaapi.OffsetCommitRequest ? -- This message was sent by Atlassian JIRA (v6.3.4#6332)