consume_messages
Read messages from a Kafka topic by specifying offset (earliest, latest, or integer) and timeout. Retrieve a limited number of records for inspection.
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 |
|---|---|---|---|
| limit | No | ||
| timeout | No | ||
| partition | No | ||
| topic_name | Yes | ||
| offset_spec | No | latest |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |