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

Utilize the new Consumer#enforceRebalance(reason) API in Streams

    XMLWordPrintableJSON

Details

    • Task
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • None
    • 3.2.0
    • streams
    • None

    Description

      KIP-800 is adding a new "reason" parameter to the Consumer#enforceRebalance API, which will be passed in to a new field of the JoinGroup protocol. We invoke this API throughout Streams for various reasons, which are very useful for debugging the cause of rebalancing. Passing in the reason to this new API would make it possible to figure out why a Streams client triggered a rebalance from the broker logs, which are often the only logs available when the client logs cannot be retrieved for whatever reason

      Attachments

        Issue Links

          is blocked by

          Sub-task - The sub-task of the issue KAFKA-13495 Add reason to JoinGroupRequest

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

          Web Link GitHub Pull Request #11804

          Web Link GitHub Pull Request #11873

          Web Link GitHub Pull Request #12018

          Activity

            People

              lihaosky Hao Li
              ableegoldman A. Sophie Blee-Goldman
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: