curl --request PATCH \
--url https://api.sequin.io/v1/http-consumers/c906b4a4-0cda-4f46-bd80-255f570c195d \
--header 'Authorization: Bearer YOUR_API_TOKEN' \
--header 'Content-Type: application/json' \
--data '{
{
"deliver_policy": "all",
"max_ack_pending": 20000,
"ack_wait_ms": 10000,
"name": "Choam Corp - Primary Consumer",
"metadata": { "custom_property": 42 }
}
}'
{
"id": "c906b4a4-0cda-4f46-bd80-255f570c195d",
"stream_id": "f0f70b52-5243-489c-879b-a1ae3f02abfd",
"deliver_policy": "all",
"ack_wait_ms": 30000,
"max_deliver": -1,
"max_ack_pending": 1000,
"name": "Choam Corp - Primary Consumer",
"metadata": { "custom_property": 42 },
"created_at": "2023-12-15 01:29:29",
"updated_at": "2023-12-15 01:29:29"
}
Consumers
Update a Consumer
This endpoint updates a Consumer.
PATCH
/
v1
/
http-consumers
/
{id}
curl --request PATCH \
--url https://api.sequin.io/v1/http-consumers/c906b4a4-0cda-4f46-bd80-255f570c195d \
--header 'Authorization: Bearer YOUR_API_TOKEN' \
--header 'Content-Type: application/json' \
--data '{
{
"deliver_policy": "all",
"max_ack_pending": 20000,
"ack_wait_ms": 10000,
"name": "Choam Corp - Primary Consumer",
"metadata": { "custom_property": 42 }
}
}'
{
"id": "c906b4a4-0cda-4f46-bd80-255f570c195d",
"stream_id": "f0f70b52-5243-489c-879b-a1ae3f02abfd",
"deliver_policy": "all",
"ack_wait_ms": 30000,
"max_deliver": -1,
"max_ack_pending": 1000,
"name": "Choam Corp - Primary Consumer",
"metadata": { "custom_property": 42 },
"created_at": "2023-12-15 01:29:29",
"updated_at": "2023-12-15 01:29:29"
}
Request parameters
You cannot update the
stream_id of an existing HTTP pull consumer.string
required
The ID of the consumer.
string
Where in the stream the consumer starts.
all(default): the consumer will start from the beginning of the stream.new: the consumer will start from the most recent message.last: the consumer will start from the last message it received.1h: the consumer will start from the most recent message from the last hour.
If you change the
deliver_policy on the consumer, records may be replayed. For example, if you change the deliver_policy from new to all, the consumer will start from the beginning of the stream and replay all records.integer
How long to wait for a message to be acknowledged, in milliseconds. Defaults to
30000 (30 seconds).If a worker doesn’t acknowledge a message within this time, the message will be redelivered (i.e. reappear for other workers to process).integer
Maximum number of times a message can be redelivered to workers. For example, if a message causes your workers to crash, it will be redelivered up to
max_deliver times before being discarded.Defaults to -1, which means there is no maximum.integer
Maximum number of outstanding, acknowledged messages a consumer will allow at a time. Defaults to
1000.After your workers have checked out max_ack_pending messages, the consumer will stop delivering messages until some are acknowledged.object
Metadata for the consumer. This is a JSON object that you can use to store any additional information you want to associate with the consumer.
curl --request PATCH \
--url https://api.sequin.io/v1/http-consumers/c906b4a4-0cda-4f46-bd80-255f570c195d \
--header 'Authorization: Bearer YOUR_API_TOKEN' \
--header 'Content-Type: application/json' \
--data '{
{
"deliver_policy": "all",
"max_ack_pending": 20000,
"ack_wait_ms": 10000,
"name": "Choam Corp - Primary Consumer",
"metadata": { "custom_property": 42 }
}
}'
Response fields
{
"id": "c906b4a4-0cda-4f46-bd80-255f570c195d",
"stream_id": "f0f70b52-5243-489c-879b-a1ae3f02abfd",
"deliver_policy": "all",
"ack_wait_ms": 30000,
"max_deliver": -1,
"max_ack_pending": 1000,
"name": "Choam Corp - Primary Consumer",
"metadata": { "custom_property": 42 },
"created_at": "2023-12-15 01:29:29",
"updated_at": "2023-12-15 01:29:29"
}
string
ID of the consumer.
string
ID of the stream the consumer reads from.
string
Where in the stream the consumer starts.
all(default): the consumer will start from the beginning of the stream.new: the consumer will start from the most recent message.last: the consumer will start from the last message it received.1h: the consumer will start from the most recent message from the last hour.
integer
How long to wait for a message to be acknowledged, in milliseconds. Defaults to
30000 (30 seconds).If a worker doesn’t acknowledge a message within this time, the message will be redelivered (i.e. reappear for other workers to process).integer
Maximum number of times a message can be redelivered to workers. For example, if a message causes your workers to crash, it will be redelivered up to
max_deliver times before being discarded.Defaults to -1, which means there is no maximum.integer
Maximum number of outstanding, acknowledged messages a consumer will allow at a time. Defaults to
1000.After your workers have checked out max_ack_pending messages, the consumer will stop delivering messages until some are acknowledged.object
Metadata for the sync. This is a JSON object that you can use to store any additional information you want to associate with the sync.
string
Timestamp of when the sync was created, in ISO 8601 format.
string
Timestamp of when the sync was last updated, in ISO 8601 format.