[ https://issues.apache.org/jira/browse/KAFKA-4471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15709355#comment-15709355 ]
Vahid Hashemian commented on KAFKA-4471: ---------------------------------------- [~salaev] Thanks for reporting the issue and providing the steps to reproduce it. I'll take a look. > 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)