You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Joel Koshy (JIRA)" <ji...@apache.org> on 2015/02/03 03:37:35 UTC

[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=14302679#comment-14302679 ] 

Joel Koshy commented on KAFKA-1870:
-----------------------------------

[~junrao] (at least on trunk) I think the change to kafka.javaapi.OffsetFetchRequest should be reverted since people who are using that original constructor should be explicitly setting the versionId to 0. The issue is that right now you cannot fetch offsets from Kafka using javaapi.

> 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)