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 策略）
Tool call template
Replace each placeholder with a value matching the input schema. Only required parameters are included; add optional parameters as needed.
{
"id": 1,
"jsonrpc": "2.0",
"method": "tools/call",
"params": {
"arguments": {
"group_id": "<group_id>",
"topic": "<topic>"
},
"name": "kafka_reset_consumer_group_offsets"
}
}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 | |||