reset_consumer_group_offset
Reset a Kafka consumer group's offset to earliest, latest, or a specific value, with dry-run and force options.
Instructions
Resets the offset of a consumer group using AdminClient. offset_spec: 'earliest', 'latest', or a specific integer offset string. dry_run: If True, only calculates and returns the proposed offset changes without applying them. force: If True, forces the modification even if the group is active or STABLE.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| force | No | ||
| dry_run | No | ||
| group_id | Yes | ||
| partition | No | ||
| topic_name | Yes | ||
| offset_spec | No | latest |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||