conduktor.io ↗

Kafka DeleteGroups Request Wire Format v2 — Binary Protocol Layout

What is DeleteGroups?

Removes consumer groups via kafka-consumer-groups.sh --delete. Only works on groups in the Empty state; attempting to delete an active group returns NON_EMPTY_GROUP. Stored offsets are also deleted, so restarting consumers will apply auto.offset.reset.

Related Errors

COORDINATOR_NOT_AVAILABLE · GROUP_AUTHORIZATION_FAILED · INVALID_GROUP_ID · NON_EMPTY_GROUP

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
DeleteGroupsRequest v2
GroupsNames []string
tagged var

Schema & Example

Schema
{
  "GroupsNames": [string]
}
Example
{
  "GroupsNames": ["value-1", "value-2"]
}