conduktor.io ↗

Kafka ShareGroupHeartbeat Request Wire Format v1 — Binary Protocol Layout

What is ShareGroupHeartbeat?

Maintains membership in a share group (KIP-932), where multiple consumers read from the same partitions cooperatively with each record delivered to exactly one consumer. Unlike classic consumer groups, partitions aren't exclusively assigned; the broker tracks delivery state per record range.

Related Errors

COORDINATOR_NOT_AVAILABLE · GROUP_AUTHORIZATION_FAILED · INVALID_REQUEST · TOPIC_AUTHORIZATION_FAILED · UNSUPPORTED_VERSION

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
ShareGroupHeartbeatRequest v1
GroupId string (compact)
MemberId string (compact)
MemberEpoch int32 · 4B
RackId? string (compact)
SubscribedTopicNames? []string
tagged var

Schema & Example

Schema
{
  "GroupId": string,
  "MemberId": string,
  "MemberEpoch": int32,
  "RackId": string?,
  "SubscribedTopicNames": [string]?
}
Example
{
  "GroupId": "order-processors",
  "MemberId": "consumer-1-abc123",
  "MemberEpoch": 12,
  "RackId": "abc-123",
  "SubscribedTopicNames": ["value-1", "value-2"]
}