What is OffsetDelete?
Clears stored offsets for specific partitions via kafka-consumer-groups.sh --delete-offsets, resetting a group's tracked position. The group must not be actively consuming those partitions, otherwise returns GROUP_SUBSCRIBED_TO_TOPIC.
Wire Diagram
Response Header
message_size
int32 · 4B
correlation_id
int32 · 4B
OffsetDeleteResponse v0
ErrorCode
int16 · 2B
ThrottleTimeMs
int32 · 4B
Name
string
PartitionIndex
int32 · 4B
ErrorCode
int16 · 2B
Schema & Example
Schema { "ErrorCode": int16, "ThrottleTimeMs": int32, "Topics": [{ "Name": string, "Partitions": [{ "PartitionIndex": int32, "ErrorCode": int16 }] }] }
Example { "ErrorCode": 0, "ThrottleTimeMs": 0, "Topics": [{ "Name": "orders", "Partitions": [{ "PartitionIndex": 3, "ErrorCode": 0 }] }] }