kafka_reset_consumer_group_offsets
Reset a Kafka consumer group's offsets for a topic to earliest, latest, a specific offset, or timestamp, using dry-run and confirmation safeguards.
Instructions
重置指定消费组在目标主题上的消费位移(高危运维操作,支持 Dry-Run 预检与 earliest/latest/to_offset/to_datetime 策略)
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| force | No | ||
| topic | Yes | ||
| offset | No | ||
| confirm | No | ||
| dry_run | No | ||
| group_id | Yes | ||
| strategy | No | earliest | |
| connection | No | ||
| partitions | No | ||
| datetime_val | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||