get_consumer_group_offsets
Retrieve committed offsets, watermarks, and lag for a Kafka consumer group and topic to monitor message processing status.
Instructions
Get the committed offsets and lag for a specific consumer group and topic. Returns the committed offset, high/low watermarks, and calculated lag for each partition.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| group_id | Yes | ||
| topic_name | Yes |