[
https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064210#comment-15064210
]
Ewen Cheslack-Postava commented on KAFKA-3006:
----------------------------------------------
We did mark the interface unstable for exactly this reason (in addition to
being able to work out any implementation bugs), and we've announced the
support as beta. Personally I think the source-compatible/binary-compatible
split is a pretty good line to draw at this point. Depending on what further
issues arise, we could even discuss non-source-compatible changes if they were
really necessary, but I think requiring recompile for 0.9.1 isn't unreasonable
unless we can come up with a good example where it's really important that we
have binary compatibility.
You could also raise this on the mailing list and we could try to formalize the
details of how we manage compatibility a bit further. There are whole bunch of
other related issues (e.g. how we schedule deprecation and removal of features)
that could also be addressed in that discussion.
> Make collection default container type for sequences in the consumer API
> ------------------------------------------------------------------------
>
> Key: KAFKA-3006
> URL: https://issues.apache.org/jira/browse/KAFKA-3006
> Project: Kafka
> Issue Type: Improvement
> Components: clients
> Affects Versions: 0.9.0.0
> Reporter: Pierre-Yves Ritschard
> Labels: patch
>
> The KafkaConsumer API has some annoying inconsistencies in the usage of
> collection types. For example, subscribe() takes a list, but subscription()
> returns a set. Similarly for assign() and assignment(). We also have pause()
> , seekToBeginning(), seekToEnd(), and resume() which annoyingly use a
> variable argument array, which means you have to copy the result of
> assignment() to an array if you want to pause all assigned partitions. We can
> solve these issues by adding the following variants:
> {code}
> void subscribe(Collection<String> topics);
> void subscribe(Collection<String> topics, ConsumerRebalanceListener);
> void assign(Collection<TopicPartition> partitions);
> void pause(Collection<TopicPartition> partitions);
> void resume(Collection<TopicPartition> partitions);
> void seekToBeginning(Collection<TopicPartition>);
> void seekToEnd(Collection<TopicPartition>);
> {code}
> This issues supersedes KAFKA-2991
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
