[KAFKA-17125] Streams Rebalance Protocol

• Type: New Feature
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: streams
• Labels: kip
• Assignee: Unassigned
• Reporter: Lucas Brutschy
• Created: 12/Jul/24 07:44
• Updated: 27/Sep/24 09:47

Description

This ticket tracks the implementation of the Streams Rebalance Protocol, as proposed in https://cwiki.apache.org/confluence/display/KAFKA/KIP-1071%3A+Streams+Rebalance+Protocol

Issue Links

• is blocked by: KAFKA-17485 Replace KafkaClientSupplier with KafkaClientInterceptor
• links to: GitHub Pull Request #17300

Sub-Tasks

• Add StreamsGroupHeartbeat RPC definitions: Resolved
• Add StreamsGroupDescribe RPC definitions: Resolved
• Add group coordinator records for Streams rebalance protocol: Resolved
• Add Admin.describeStreamsGroups: Open
• Add support for streams groups to kafka-group.sh: Open
• Add support for kafka-streams-groups.sh --list: Open
• Add support kafka-streams-groups.sh --describe: Open
• Port tooling to configure topologies to broker: In Progress
• Add task assignor interfaces: Patch Available
• Add StreamsGroupMember, MemberState and Assignment classes: Open
• Add StickyTaskAssignor: Open
• Add StreamsGroup class: Open
• Add CurrentAssignmentBuilder: Open
• Add TargetAssignmentBuilder: Open