Pushes messages to a Redis (v5.0+) Stream (which is created if it doesn't already exist) using the XADD command.
# Config fields, showing default valuesoutput:redis_streams:url: tcp://localhost:6379stream: benthos_streambody_key: bodymax_length: 0max_in_flight: 1
It's possible to specify a maximum length of the target stream by setting it to a value greater than 0, in which case this cap is applied only when Redis is able to remove a whole macro node, for efficiency.
Redis stream entries are key/value pairs, as such it is necessary to specify the key to be set to the body of the message. All metadata fields of the message will also be set as key/value pairs, if there is a key collision between a metadata item and the body then the body takes precedence.
This output benefits from sending multiple messages in flight in parallel for
improved performance. You can tune the max number of in flight messages with the
The URL of a Redis server to connect to.
# Examplesurl: tcp://localhost:6379
The stream to add messages to.
A key to set the raw body of the message to.
When greater than zero enforces a rough cap on the length of the target stream.
The maximum number of messages to have in flight at a given time. Increase this to improve throughput.