HTTP Topic API
Both endpoints require bearer auth and role in {service, dba, system}.
POST /v1/api/topics/consume
{
"topic_id": "orders_topic",
"group_id": "worker_group",
"start": "Latest",
"limit": 100,
"partition_id": 0,
"timeout_seconds": 10
}POST /v1/api/topics/ack
{
"topic_id": "orders_topic",
"group_id": "worker_group",
"partition_id": 0,
"upto_offset": 10
}For SQL-based topic workflows, see SQL Topics & Consumers.
Last updated on