Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14048 The Next Generation of the Consumer Rebalance Protocol
  3. KAFKA-15278

Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC

Agile BoardAttach filesAttach ScreenshotVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    Description

      The necessary Java code that represents the ConsumerGroupHeartbeatRequest and ConsumerGroupHeartbeatResponse are already present in the codebase. It is assumed that the scaffolding for the other two will come along in time.

      • Implement ConsumerGroupRequestManager
      • Ensure that DefaultBackgroundThread correctly calculates I/O timeouts so that the heartbeat occurs within the group.consumer.session.timeout.ms interval regardless of other RequestManager instance activity
      • Ensure error is handled correctly
      • Ensure MembershipStateManager is updated on both successful and failures cases, and the state machine is transioned to the correct state.

      This task is part of the work to implement support for the new KIP-848 consumer group protocol.

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            kirktrue Kirk True
            kirktrue Kirk True
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment