Jason Gustafson created KAFKA-4693:
--------------------------------------
Summary: Consumer subscription change during rebalance causes
exception
Key: KAFKA-4693
URL: https://issues.apache.org/jira/browse/KAFKA-4693
Project: Kafka
Issue Type: Bug
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)
