rewind_consumer_group_offset_by_timestamp
Reset Kafka consumer group offsets to a specific timestamp. Use this tool to replay messages from a chosen time point or recover from processing errors by adjusting offsets.
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
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| group_id | Yes | ||
| topic_name | Yes | ||
| timestamp_ms | Yes | ||
| partition | No | ||
| dry_run | No | ||
| force | No |