rewind_consumer_group_offset_by_timestamp
Rewind consumer group offsets to a specific timestamp in Kafka. Use dry_run to preview changes without applying. Force applies even for 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 |
|---|---|---|---|
| group_id | Yes | ||
| topic_name | Yes | ||
| timestamp_ms | Yes | ||
| partition | No | ||
| dry_run | No | ||
| force | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||