KIP-1331 — Streams Group Topology Description Plugin

Accepted Kafka 4.4 StreamsBrokerProtocol

Adds a StreamsGroupTopologyDescriptionUpdate RPC plus a TopologyDescriptionRequired flag in StreamsGroupHeartbeatResponse, letting the broker request a client's full processing graph and hand it to a pluggable group.streams.topology.description.plugin.class backend for storage and presentation. KIP-1071 only sends the coordinator the assignment subset of the topology (subtopologies, source and changelog topics, copartition groups), so the source, processor, and sink nodes and their state stores stay invisible to operators diagnosing degradation or long rebalances without access to application code.

Protocol Impact

StreamsGroupHeartbeat v1 · StreamsGroupDescribe v1 · Heartbeat · DeleteGroups · StreamsGroupTopologyDescriptionUpdate

Details