What is AlterShareGroupOffsets?
Resets or advances a share group's start offset for specific partitions, the equivalent of kafka-consumer-groups.sh --reset-offsets for share groups. Use this to skip over poison-pill records causing repeated delivery failures across all members.
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
AlterShareGroupOffsetsRequest v0
GroupId
string (compact)
tagged
var
TopicName
string (compact)
tagged
var
PartitionIndex
int32 · 4B
StartOffset
int64 · 8B
tagged
var
Schema & Example
Schema { "GroupId": string, "Topics": [{ "TopicName": string, "Partitions": [{ "PartitionIndex": int32, "StartOffset": int64 }] }] }
Example { "GroupId": "order-processors", "Topics": [{ "TopicName": "orders", "Partitions": [{ "PartitionIndex": 3, "StartOffset": 150382 }] }] }