[jira] [Commented] (KAFKA-1870) Cannot commit with simpleConsumer on Zookeeper only with Java API
[ https://issues.apache.org/jira/browse/KAFKA-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14281389#comment-14281389 ] Thomas Vandevelde commented on KAFKA-1870: -- Thanks for the very quick fix guys! It was indeed blocking us to move from 0.8.1 to 0.8.2 I can see that only the javaapi version is restricted to use v0, The scala one still has v1 as default. Is it expected? In our case, i suppose we will wait for the new kafkaconsumer to commit to kafka instead of zookeeper. Do you know when 0.8.2 will be released by any chance? > 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 >Assignee: Jun Rao >Priority: Blocker > Fix For: 0.8.2 > > Attachments: OffsetCommitRequest.diff, kafka-1870.patch, > kafka-1870_2015-01-16_12:08:05.patch > > 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)
[jira] [Commented] (KAFKA-1870) Cannot commit with simpleConsumer on Zookeeper only with Java API
[ https://issues.apache.org/jira/browse/KAFKA-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14280632#comment-14280632 ] Thomas Vandevelde commented on KAFKA-1870: -- Do you mean we should then have the default version 0 instead of 1 in OffsetCommitRequest ? > 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)
[jira] [Updated] (KAFKA-1870) Cannot commit with simpleConsumer on Zookeeper only with Java API
[ https://issues.apache.org/jira/browse/KAFKA-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Vandevelde updated KAFKA-1870: - Attachment: OffsetCommitRequest.diff Patch attached > 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 >Assignee: Neha Narkhede >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)
[jira] [Created] (KAFKA-1870) Cannot commit on Zookeeper only with Java API
Thomas Vandevelde created KAFKA-1870: Summary: Cannot commit 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 Assignee: Neha Narkhede Priority: Minor >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)
[jira] [Updated] (KAFKA-1870) Cannot commit with simpleConsumer on Zookeeper only with Java API
[ https://issues.apache.org/jira/browse/KAFKA-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Vandevelde updated KAFKA-1870: - Summary: Cannot commit with simpleConsumer on Zookeeper only with Java API (was: Cannot commit on Zookeeper only with Java API) > 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 >Assignee: Neha Narkhede >Priority: Minor > 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)
