Keyboard shortcuts

Press or to navigate between chapters

Press S or / to search in the book

Press ? to show this help

Press Esc to hide this help

Redis Streams

Schemes: redis://, rediss://, redis_streams://

Query parameters recognised as config fields for this connector. Any other ?key=value pair is passed through unchanged as a driver option on the connection URL.

NameTypeRequiredDefaultDescription
approx_trimbooleanno(Publisher) Use approximate (~) trimming when maxlen is set. Defaults to true.
block_msintegerno(Consumer) Block timeout in milliseconds for each read. Defaults to 5000ms.
consumer_namestringno(Consumer) Consumer name within the group. Defaults to a unique per-instance id.
groupstringno(Consumer) Group name. Defaults to {APP_NAME}-{stream}; ignored in subscriber_mode.
internal_buffer_sizeintegernoInternal buffer size for the consumer channel. Defaults to 128.
maxlenintegerno(Publisher) If set, cap the stream length with XADD MAXLEN.
passwordstringnoOptional password for authentication.
read_from_startbooleannofalse(Consumer) On group creation, start from the stream beginning (“0”) not “$”. Default false.
reader_connectionsintegerno(Consumer) Parallel XREADGROUP reader connections fanned out across the group. Default 1. Ignored in subscriber_mode.
redelivery_timeout_msintegerno(Consumer) Redeliver entries pending ≥ this long via XAUTOCLAIM; 0 disables. Default 60000ms.
streamstringnoThe stream key to publish to or read from. Defaults to the route name.
subscriber_modebooleannofalse(Consumer) Read ephemerally via XREAD from new messages (no group/acks). Default false.
urlstringyesRedis URL, redis:// or rediss:// for TLS. Userinfo is treated as a secret.
usernamestringnoOptional username for authentication (Redis ACL).