consume_messages
Consume messages from a Kafka topic with configurable offset (earliest, latest, or specific integer) and timeout, returning messages up to a set limit.
Instructions
Consumes messages from a topic. offset_spec: 'earliest', 'latest', or specific integer offset. timeout: seconds to wait for messages.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| topic_name | Yes | ||
| partition | No | ||
| offset_spec | No | latest | |
| limit | No | ||
| timeout | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |