What is StreamsGroupTopologyDescriptionUpdate?
Pushes a Streams application's topology description — subtopologies, processing nodes, and global state stores — to the group coordinator, which hands it to the configured topology description plugin (KIP-1331). Clients send it when a StreamsGroupHeartbeat response sets TopologyDescriptionRequired, and a member no longer in the group is rejected with UNKNOWN_MEMBER_ID so it treats itself as fenced and rejoins. Added on trunk after 4.3 — no released broker accepts it.
| Version | Kafka | Changes |
|---|---|---|
| StreamsGroupTopologyDescriptionUpdateRequest | ||
| v0 | + GroupId string+ MemberId string+ TopologyEpoch int32+ TopologyDescription TopologyDescription+ Subtopologies []TopologyDescriptionSubtopology+ SubtopologyId string+ Nodes []TopologyDescriptionNode+ Name string+ NodeType int8+ SourceTopics []string+ SinkTopic string+ Stores []string+ Successors []string+ GlobalStores []TopologyDescriptionGlobalStore+ Source TopologyDescriptionNode+ Name string+ NodeType int8+ SourceTopics []string+ SinkTopic string+ Stores []string+ Successors []string+ Processor TopologyDescriptionNode+ Name string+ NodeType int8+ SourceTopics []string+ SinkTopic string+ Stores []string+ Successors []string~ Flexible encoding enabled FLEXIBLE | |
| StreamsGroupTopologyDescriptionUpdateResponse | ||
| v0 | + ThrottleTimeMs int32+ ErrorCode int16+ ErrorMessage string~ Flexible encoding enabled FLEXIBLE | |