API Reference
Hanzo Stream API
Hanzo Stream is a Kafka-compatible streaming gateway built on Hanzo PubSub.
Hanzo Stream is a Kafka-compatible streaming gateway built on Hanzo PubSub.
Hanzo Stream API · Guide & examples → · All API references →
| Base URL | https://stream.hanzo.ai |
| Version | 1.0.0 |
| Operations | 14 |
| Guide | Hanzo Stream API guide |
Authentication
bearerAuth— HTTP bearerBearerAuth— HTTP bearer
All Hanzo APIs share one bearer credential and common error and pagination conventions. See API conventions.
curl -H "Authorization: Bearer $HANZO_API_KEY" https://stream.hanzo.aiEndpoints
Brokers
| Method | Endpoint | Description |
|---|---|---|
GET | /v1/stream/brokers | List broker instances |
GET | /v1/stream/brokers/config | Get broker configuration |
Consumer Groups
| Method | Endpoint | Description |
|---|---|---|
GET | /v1/stream/groups | List consumer groups |
GET | /v1/stream/groups/{group_id} | Get consumer group details |
DELETE | /v1/stream/groups/{group_id} | Delete a consumer group |
GET | /v1/stream/groups/{group_id}/offsets | Get committed offsets |
PUT | /v1/stream/groups/{group_id}/offsets | Commit offsets |
Health
| Method | Endpoint | Description |
|---|---|---|
GET | /health | Health check |
Messages
| Method | Endpoint | Description |
|---|---|---|
GET | /v1/stream/topics/{topic}/messages | Consume messages |
POST | /v1/stream/topics/{topic}/messages | Produce messages |
Topics
| Method | Endpoint | Description |
|---|---|---|
GET | /v1/stream/topics | List topics |
POST | /v1/stream/topics | Create a topic |
GET | /v1/stream/topics/{topic} | Get topic metadata |
DELETE | /v1/stream/topics/{topic} | Delete a topic |
How is this guide?