Sergey Alaev created KAFKA-4471:
-----------------------------------
Summary: KafkaConsumer unpauses queues 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
How to reproduce:
1. initialize KafkaConsumer and subscribe to some topics by calling `void
subscribe(Collection<String> topics)`
2. pause some subscribed queues
3. call `void subscribe(Collection<String> topics)` with one more topic
4. paused queues will unpause.
We are using 3-node Kafka cluster, server version = client version = 0.10.0.0.
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)
