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_sizeintegerno—Internal buffer size for the consumer channel. Defaults to 128.
maxlenintegerno—(Publisher) If set, cap the stream length with XADD MAXLEN.
passwordstringno—Optional 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.
streamstringno—The 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.
urlstringyes—Redis URL, redis:// or rediss:// for TLS. Userinfo is treated as a secret.
usernamestringno—Optional username for authentication (Redis ACL).