Synadia Connect

NATS JetStream

NAMERUNTIMETYPEVERSIONSTATUS
nats_jetstreamwombatsourcelateststable

Reads messages from NATS JetStream subjects.

Configuration

nametypeoptionalsecretdescription
urls[]stringnonoA list of URLs to connect to. If an item of the list contains commas it will be expanded into multiple URLs.
queuestringyesnoAn optional queue group to consume as. Used to configure a push consumer.
subjectstringnonoA subject to consume from. Supports wildcards for consuming multiple subjects. Either a subject or stream must be specified.
durablestringyesnoPreserve the state of your consumer under a durable name. Used to configure a pull consumer.
streamstringyesnoA stream to consume from. Either a subject or stream must be specified.
bindboolyesnoIndicates that the subscription should use an existing consumer. The value defaults to false.
deliverstringyesnoDetermines which messages to deliver when consuming without a durable subscriber. The value should be one of all, last, last_per_subject or new. The value defaults to all.
ack_waitstringyesnoThe maximum amount of time NATS server should wait for an ack from consumer. The value defaults to 30s.
max_ack_pendingintyesnoThe maximum number of outstanding acks to be allowed before consuming is halted. The value defaults to 1024.
authauthyesnoOptional configuration of NATS authentication parameters.

Auth

nametypeoptionalsecretdescription
user_jwtstringyesnoAn optional plain text user JWT (given along with the corresponding user NKey Seed).
user_nkey_seedstringyesnoAn optional plain text user NKey Seed (given along with the corresponding user JWT).
Previous
NATS