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)