nsq

Publish to an NSQ topic.

output:
nsq:
nsqd_tcp_address: localhost:4150
topic: benthos_messages
user_agent: benthos_producer
max_in_flight: 1

The topic field can be dynamically set using function interpolations described here. When sending batched messages these interpolations are performed per message part.

Performance

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 field max_in_flight.

Fields

nsqd_tcp_address

string The address of the target NSQD server.

topic

string The topic to publish to.

This field supports interpolation functions.

user_agent

string A user agent string to connect with.

tls

object Custom TLS settings can be used to override system defaults.

tls.enabled

bool Whether custom TLS settings are enabled.

tls.skip_cert_verify

bool Whether to skip server side certificate verification.

tls.root_cas_file

string The path of a root certificate authority file to use.

tls.client_certs

array A list of client certificates to use.

# Examples
client_certs:
- cert: foo
key: bar
client_certs:
- cert_file: ./example.pem
key_file: ./example.key

max_in_flight

number The maximum number of messages to have in flight at a given time. Increase this to improve throughput.