reset_consumer_group_offset
Reset Kafka consumer group offsets to earliest, latest, or specific positions. Use dry-run to preview changes or force to modify active groups.
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
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| group_id | Yes | ||
| topic_name | Yes | ||
| partition | No | ||
| offset_spec | No | latest | |
| dry_run | No | ||
| force | No |