kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jason Gustafson (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-4693) Consumer subscription change during rebalance causes exception
Date Tue, 24 Jan 2017 21:19:26 GMT
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:

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

View raw message