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.
| Version | Kafka | Changes |
|---|---|---|
| FindCoordinatorRequest | ||
| v0 | 2.2 | + Key string |
| v1 | 2.2 | + KeyType int8adds KeyType. |
| v2 | 2.2 | is the same as version 1. |
| v3 | 2.4 | ~ Flexible encoding enabled FLEXIBLE is the first flexible version. |
| v4 | 3.0 | + CoordinatorKeys []string- Key stringadds support for batching via CoordinatorKeys (KIP-699) |
| v5 | 3.8 | adds support for new error code TRANSACTION_ABORTABLE (KIP-890). |
| v6 | 3.9 | adds support for share groups (KIP-932). For key type SHARE (2), the coordinator key format is "groupId:topicId:partition". |
| FindCoordinatorResponse | ||
| v0 | 2.2 | + ErrorCode int16+ NodeId int32+ Host string+ Port int32 |
| v1 | 2.2 | + ThrottleTimeMs int32+ ErrorMessage stringadds throttle time and error messages. |
| v2 | 2.2 | on quota violation, brokers send out responses before throttling. |
| v3 | 2.4 | ~ Flexible encoding enabled FLEXIBLE is the first flexible version. |
| v4 | 3.0 | + Coordinators []Coordinator+ Key string+ NodeId int32+ Host string+ Port int32+ ErrorCode int16+ ErrorMessage string- ErrorCode int16- ErrorMessage string- NodeId int32- Host string- Port int32adds support for batching via Coordinators (KIP-699) |
| v5 | 3.8 | adds support for new error code TRANSACTION_ABORTABLE (KIP-890). |
| v6 | 3.9 | adds support for share groups (KIP-932). |