KAFKA-3006 is under review, and would change some commonly used
signatures in the Kafka client library. The idea behind the proposal is
to provide a unified way of interacting with anything sequence like in
the client.

If the change is accepted, these would be the signatures that change:

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

Reply via email to