put_ksqldb_query
Run ksqlDB pull queries on Kafka clusters to retrieve current data from materialized views, enabling direct answers to streaming data questions.
Instructions
Execute a ksqlDB pull query
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": {
"cluster": "<cluster>",
"ksqldb": "<ksqldb>",
"sql": "<sql>"
},
"name": "put_ksqldb_query"
}
}Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| sql | Yes | The SQL query to execute | |
| ksqldb | Yes | ksqlDB cluster name | |
| cluster | Yes | Cluster name |