conduktor.io ↗

Kafka StreamsGroupTopologyDescriptionUpdate Response Wire Format v0 — Binary Protocol Layout

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.

Related Errors

COORDINATOR_NOT_AVAILABLE · GROUP_AUTHORIZATION_FAILED · STREAMS_TOPOLOGY_DESCRIPTION_UPDATE_FAILED · UNSUPPORTED_VERSION

Wire Diagram

Response Header · flexible
message_size int32 · 4B
correlation_id int32 · 4B
tagged var
StreamsGroupTopologyDescriptionUpdateResponse v0
ThrottleTimeMs int32 · 4B
ErrorCode int16 · 2B
ErrorMessage? string (compact)
tagged var

Schema & Example

Schema
{
  "ThrottleTimeMs": int32,
  "ErrorCode": int16,
  "ErrorMessage": string?
}
Example
{
  "ThrottleTimeMs": 0,
  "ErrorCode": 0,
  "ErrorMessage": "NETWORK_EXCEPTION"
}