consume_messages
Read messages from a Kafka topic with configurable offset, partition, and timeout settings to monitor or process streaming data.
Instructions
Consumes messages from a topic. offset_spec: 'earliest', 'latest', or specific integer offset. timeout: seconds to wait for messages.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| topic_name | Yes | ||
| partition | No | ||
| offset_spec | No | latest | |
| limit | No | ||
| timeout | No |