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

When subscription set changes on new consumer, the partitions may be removed without offset being committed.

    XMLWordPrintableJSON

    Details

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

      Description

      When users are using group management, if they call consumer.subscribe() to change the subscription, the removed subscriptions will be immediately removed and their offset will not be commit. Also the revoked partitions passed to the ConsumerRebalanceListener.onPartitionsRevoked() will not include those partitions.

        Attachments

          Issue Links

          Is contained by

          Bug - A problem which impairs or prevents the functions of the product. KAFKA-4033 KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #1363

            Activity

              People

              • Assignee:
                vahid Vahid Hashemian
                Reporter:
                becket_qin Jiangjie Qin
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: