[KAFKA-15278] Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.7.0
• Component/s: clients, consumer
• Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview
• Assignee: Kirk True
• Reporter: Kirk True
• Created: 01/Aug/23 00:16
• Updated: 19/Dec/23 03:15
• Resolved: 09/Oct/23 17:34

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.

Issue Links

• relates to: KAFKA-15280 Implement client support for selecting KIP-848 server-side assignor
• links to: GitHub Pull Request #14364