You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/12/06 02:17:58 UTC

[jira] [Commented] (KAFKA-4471) KafkaConsumer unpauses partitions after subscribe()

    [ https://issues.apache.org/jira/browse/KAFKA-4471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724068#comment-15724068 ] 

Vahid Hashemian commented on KAFKA-4471:
----------------------------------------

[~hachikuji] Thanks for the clarification.
[~salaev] I'll close this JIRA based on [~hachikuji]'s explanation. Please advise if you disagree.

> 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)