[
https://issues.apache.org/jira/browse/KAFKA-4471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vahid Hashemian reassigned KAFKA-4471:
--------------------------------------
Assignee: Vahid Hashemian
> KafkaConsumer unpauses partitions after subscribe()
> ---------------------------------------------------
>
> Key: KAFKA-4471
> URL: https://issues.apache.org/jira/browse/KAFKA-4471
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 0.10.0.0
> Reporter: Sergey Alaev
> Assignee: Vahid Hashemian
>
> How to reproduce:
> 1. initialize KafkaConsumer and subscribe to some topics by calling `void
> subscribe(Collection<String> topics)`
> 2. pause some subscribed partitions
> 3. call `void subscribe(Collection<String> topics)` with one more topic
> 4. paused partitions will unpause.
> We are using 3-node Kafka cluster, server version = client version =
> 0.10.0.0., one partition per topic
> Note:
> There was another problem with 0.9.x - that client did not purge unsubscribed
> queues if they are paused. Probably that got 'fixed'.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
