[
https://issues.apache.org/jira/browse/KAFKA-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14280778#comment-14280778
]
Joel Koshy commented on KAFKA-1870:
-----------------------------------
This is a pretty severe limitation of the scala javaapi request definitions.
i.e., we don't provide explicit constructors for different versions (as we do
in the Java request definitions in the clients package). We should really get
rid of these and move completely over to the Java request definitions in the
next or next++ release - so on that note I think it is reasonable to pin the
version and enforce SimpleConsumer commits/fetches only to/from ZK.
> 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: Minor
> 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)
