STstreamkap
Topics

Execute SQL query against Kafka topics

Changed on

Parse and execute a SQL query against a Kafka topic.

post/topics/query

Request

Request body

sqlstring required

SQL query string (e.g., SELECT * FROM topic_name WHERE ... LIMIT 10)

max_time_secondsinteger

Maximum execution time in seconds before the query is terminated

Response

Successful Response

columnsstring[]

Column names in the result set

rowsobject[]

Result rows as dicts

errorstring nullable

Error message if the query failed

Changes