conduktor.io ↗

Kafka FindCoordinator Request Wire Format v1 — Binary Protocol Layout

What is FindCoordinator?

The first step before any group or transaction operation: locates the group coordinator or transaction coordinator. A COORDINATOR_NOT_AVAILABLE response means the __consumer_offsets or __transaction_state partition leader is still being elected; retry with backoff.

Related Errors

COORDINATOR_NOT_AVAILABLE · GROUP_AUTHORIZATION_FAILED · INVALID_REQUEST · TRANSACTIONAL_ID_AUTHORIZATION_FAILED

Wire Diagram

Request Header
message_size int32 · 4B
api_key int16 · 2B
api_version int16 · 2B
correlation_id int32 · 4B
client_id string
FindCoordinatorRequest v1
Key string
KeyType int8 · 1B

Schema & Example

Schema
{
  "Key": string,
  "KeyType": int8
}
Example
{
  "Key": "retention.ms",
  "KeyType": 1
}