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

Allow explicit rebalance triggering on the Consumer

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 2.6.0
    • clients

    Description

      Currently the only way to explicitly trigger a rebalance is by unsubscribing the consumer. This has two drawbacks: it does not work with static membership, and it causes the consumer to revoke all its currently owned partitions. Streams relies on being able to enforce a rebalance for its version probing upgrade protocol and the upcoming KIP-441, both of which should be able to work with static membership and be able to leverage the improvements of KIP-429 to no longer revoke all owned partitions.

      We should add an API that will allow users to explicitly trigger a rebalance without going through #unsubscribe

      Attachments

        Issue Links

          Activity

            People

              ableegoldman A. Sophie Blee-Goldman
              ableegoldman A. Sophie Blee-Goldman
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: