update_consumer_group_topic_partition_offset
Modify consumer group offsets for specific Kafka topic partitions to control data consumption or recover from processing issues.
Instructions
Update the offset for a topic-partition for a given group.
Args: environment: The environment name. group_id: The ID of the consumer group. topic: The topic name. partition: The partition number. offset: The new offset value.
Returns: The result of the update operation.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| group_id | Yes | ||
| topic | Yes | ||
| partition | Yes | ||
| offset | Yes |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||