Skip to main content
POST
/
storage
/
streams
Create a new stream
curl --request POST \
  --url https://api.quiva.ai/storage/streams \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "name": "my-stream",
  "description": "My event stream",
  "subjects": [
    "events.*",
    "logs.*"
  ],
  "max_consumers": 5,
  "max_msgs": 1000000,
  "max_bytes": 104857600,
  "discard": 0,
  "max_msgs_per_subject": 1000,
  "max_msg_size": 8192,
  "storage": 0,
  "num_replicas": 3
}
'
{
  "message": "success"
}

Authorizations

​
Authorization
string
header
required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Body

application/json
​
name
string
required

Name of the stream to create

​
description
string

Description of the stream

​
subjects
string[]

Subject patterns to capture

​
max_consumers
integer

Maximum number of consumers

Required range: x >= 1
​
max_msgs
integer

Maximum number of messages

Required range: x >= 1
​
max_bytes
integer

Maximum size in bytes

Required range: x >= 1
​
discard
enum<integer>
default:0

Discard policy (0 = old, 1 = new)

Available options:
0,
1
​
max_msgs_per_subject
integer

Maximum messages per subject

Required range: x >= 1
​
max_msg_size
integer

Maximum message size in bytes

Required range: x >= 1
​
storage
enum<string>
Available options:
file,
memory
​
num_replicas
integer
default:1

Number of replicas

Required range: x >= 1
​
mirror
object
​
sources
object[]

Optional sources configuration

​
sealed
boolean
default:false

Whether the stream is sealed

​
deny_delete
boolean
default:false

Whether deletes are denied

​
deny_purge
boolean
default:false

Whether purges are denied

Response

Bad Request

​
message
string
Example:

"success"