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

GroupMetadataManager unloads all groups in removeGroupsForPartitions

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 0.9.0.1
    • None
    • 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

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

            Dates

              Created:
              Updated:
              Resolved: