Jason Gustafson created KAFKA-2913:
--------------------------------------

             Summary: GroupMetadataManager unloads all groups in 
removeGroupsForPartitions
                 Key: KAFKA-2913
                 URL: https://issues.apache.org/jira/browse/KAFKA-2913
             Project: Kafka
          Issue Type: Bug
            Reporter: Jason Gustafson
            Assignee: Jason Gustafson


In GroupMetadataManager.removeGroupsForPartition, we currently remove all 
groups from the cache, but we should only be removing groups for the respective 
partition. This will cause an unneeded rebalance for groups mistakenly removed. 
And since the generation would reset to 0 in this case, the offsets from the 
current generation would be rejected and the consumer would see duplicates.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to