pulsar_consume
Consume messages from a Pulsar topic by specifying the topic and subscription name, with an optional limit on the number of messages.
Instructions
Consume messages from a Pulsar topic
Tool call template
Replace each placeholder with a value matching the input schema. Only required parameters are included; add optional parameters as needed.
{
"id": 1,
"jsonrpc": "2.0",
"method": "tools/call",
"params": {
"arguments": {
"topic": "<topic>",
"subscription_name": "<subscription_name>"
},
"name": "pulsar_consume"
}
}Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| topic | Yes | The Pulsar topic to consume from | |
| max_messages | No | Maximum number of messages to consume | |
| subscription_name | Yes | The subscription name for consuming messages |