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.
| Version | Kafka | Changes |
|---|---|---|
| DeleteGroupsRequest | ||
| v0 | 2.2 | + GroupsNames []string |
| v1 | 2.2 | is the same as version 0. |
| v2 | 2.4 | ~ Flexible encoding enabled FLEXIBLE is the first flexible version. |
| v3 | corresponds to the addition of an ErrorMessage field on each per-group result in the response (populated when the broker needs to surface a cause to the caller). The request body shape is unchanged at version 3. | |
| DeleteGroupsResponse | ||
| v0 | 2.2 | + ThrottleTimeMs int32+ Results []DeletableGroupResult+ GroupId string+ ErrorCode int16 |
| v1 | 2.2 | on quota violation, brokers send out responses before throttling. |
| v2 | 2.4 | ~ Flexible encoding enabled FLEXIBLE is the first flexible version. |
| v3 | + ErrorMessage stringadds the per-group ErrorMessage field so the broker can surface a cause string when GROUP_DELETION_FAILED (or any other non-NONE error) is returned for a group. | |