Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2913

GroupMetadataManager unloads all groups in removeGroupsForPartitions

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.9.0.1
    • Component/s: None
    • Labels:
      None

      Description

      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.

        Attachments

          Activity

            People

            • Assignee:
              hachikuji Jason Gustafson
              Reporter:
              hachikuji Jason Gustafson
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: