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)