conduktor.io ↗

Kafka FindCoordinator Request Wire Format v6 — 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 · flexible
message_size int32 · 4B
api_key int16 · 2B
api_version int16 · 2B
correlation_id int32 · 4B
client_id string (compact)
tagged var
FindCoordinatorRequest v6
KeyType int8 · 1B
CoordinatorKeys []string
tagged var

Schema & Example

Schema
{
  "KeyType": int8,
  "CoordinatorKeys": [string]
}
Example
{
  "KeyType": 1,
  "CoordinatorKeys": ["value-1", "value-2"]
}