rewind_consumer_group_offset_by_timestamp
Rewinds consumer group offsets to a specified timestamp. Optionally dry-run to preview changes or force action on active groups.
Instructions
Rewinds consumer group offsets manually based on a specific timestamp. Finds offsets matching the timestamp using Consumer, then sets using AdminClient. 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 | ||
| timestamp_ms | Yes |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||