oci_kafka_reset_consumer_offset
Reset consumer group offsets to earliest, latest, or a specific offset for a topic. Requires empty group and enabled writes.
Instructions
Reset consumer group offsets for a topic. THIS IS A DESTRUCTIVE OPERATION.
The consumer group must have no active members (EMPTY state). Requires --allow-writes to be enabled. This is a HIGH RISK operation that requires confirmation.
Args: group_id: The consumer group ID to reset offsets for. topic_name: The topic to reset offsets for. strategy: Reset strategy — 'earliest' (beginning), 'latest' (end), or a specific integer offset. partition: Optional specific partition number. If omitted, resets all partitions.
Returns the reset status and new offset positions for each partition.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| group_id | Yes | ||
| strategy | No | latest | |
| partition | No | ||
| topic_name | Yes |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |