[
https://issues.apache.org/jira/browse/KAFKA-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-4693:
-----------------------------------
Component/s: consumer
> Consumer subscription change during rebalance causes exception
> --------------------------------------------------------------
>
> Key: KAFKA-4693
> URL: https://issues.apache.org/jira/browse/KAFKA-4693
> Project: Kafka
> Issue Type: Bug
> Components: consumer
> Reporter: Jason Gustafson
> Priority: Minor
> Fix For: 0.10.3.0
>
>
> After every rebalance, the consumer validates that the assignment received
> contains only partitions from topics that were subscribed. If not, then we
> raise an exception to the user. It is possible for a wakeup or an interrupt
> to leave the consumer with a rebalance in progress (e.g. with a JoinGroup to
> the coordinator in-flight). If the user then changes the topic subscription,
> then this validation upon completion of the rebalance will fail. We should
> probably detect the subscription change, eat the exception, and request
> another rebalance.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
