[
https://issues.apache.org/jira/browse/KAFKA-4471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708867#comment-15708867
]
Sergey Alaev commented on KAFKA-4471:
-------------------------------------
We are using single KafkaConsumer instance to manage many topics, one partition
per topic since 0.9.x. Care is taken to work with KafkaConsumer from single
thread yet there are many bugs we had to work around. For example, call to
pause() can be ignored in some circumstances. If you want, I can create more
jira issues.
> 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
>
> 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)
