Kafka Configs Kafka Protocol Wire Format API Versions KIPs Errors Kafka Upgrade Config Advisor Flink SQL
conduktor.io ↗

Kafka DescribeShareGroupOffsets Response Wire Format v1 — Binary Protocol Layout

What is DescribeShareGroupOffsets?

Shows consumption progress of a share group, specifically the start offset and state epoch per partition. Unlike consumer group offsets (a single committed offset), share group state is more complex because multiple records can be in-flight simultaneously.

Related Errors

COORDINATOR_NOT_AVAILABLE · GROUP_AUTHORIZATION_FAILED · TOPIC_AUTHORIZATION_FAILED · UNSUPPORTED_VERSION

Wire Diagram

Response Header · flexible
message_size int32 · 4B
correlation_id int32 · 4B
tagged var
DescribeShareGroupOffsetsResponse v1
ThrottleTimeMs int32 · 4B
Groups array
tagged var
GroupId string (compact)
Topics array
ErrorCode int16 · 2B
ErrorMessage? string (compact)
tagged var
TopicName string (compact)
TopicId uuid · 16B
Partitions array
tagged var
PartitionIndex int32 · 4B
StartOffset int64 · 8B
LeaderEpoch int32 · 4B
Lag int64 · 8B
ErrorCode int16 · 2B
ErrorMessage? string (compact)
tagged var

Schema & Example

Schema
{
  "ThrottleTimeMs": int32,
  "Groups": [{
      "GroupId": string,
      "Topics": [{
          "TopicName": string,
          "TopicId": uuid,
          "Partitions": [{
              "PartitionIndex": int32,
              "StartOffset": int64,
              "LeaderEpoch": int32,
              "Lag": int64,
              "ErrorCode": int16,
              "ErrorMessage": string?
          }]
      }],
      "ErrorCode": int16,
      "ErrorMessage": string?
  }]
}
Example
{
  "ThrottleTimeMs": 0,
  "Groups": [{
      "GroupId": "order-processors",
      "Topics": [{
          "TopicName": "orders",
          "TopicId": "550e8400-e29b-41d4-a716-446655440000",
          "Partitions": [{
              "PartitionIndex": 3,
              "StartOffset": 150382,
              "LeaderEpoch": 17,
              "Lag": 0,
              "ErrorCode": 0,
              "ErrorMessage": null
          }]
      }],
      "ErrorCode": 0,
      "ErrorMessage": null
  }]
}