[
https://issues.apache.org/jira/browse/KAFKA-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4693:
-----------------------------------
Fix Version/s: (was: 2.2.0)
> 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
>
> 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
(v7.6.3#76005)
