nsq

Subscribe to an NSQ instance topic and channel.

# Common config fields, showing default values
input:
nsq:
nsqd_tcp_addresses:
- localhost:4150
lookupd_http_addresses:
- localhost:4161
topic: benthos_messages
channel: benthos_stream
user_agent: benthos_consumer
max_in_flight: 100

Fields

nsqd_tcp_addresses

A list of nsqd addresses to connect to.

Type: array
Default: ["localhost:4150"]

lookupd_http_addresses

A list of nsqlookupd addresses to connect to.

Type: array
Default: ["localhost:4161"]

tls

Custom TLS settings can be used to override system defaults.

Type: object
Default: {"client_certs":[],"enabled":false,"root_cas_file":"","skip_cert_verify":false}

tls.enabled

Whether custom TLS settings are enabled.

Type: bool
Default: false

tls.skip_cert_verify

Whether to skip server side certificate verification.

Type: bool
Default: false

tls.root_cas_file

The path of a root certificate authority file to use.

Type: string
Default: ""

tls.client_certs

A list of client certificates to use.

Type: array
Default: []

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

topic

The topic to consume from.

Type: string
Default: "benthos_messages"

channel

The channel to consume from.

Type: string
Default: "benthos_stream"

user_agent

A user agent to assume when connecting.

Type: string
Default: "benthos_consumer"

max_in_flight

The maximum number of pending messages to consume at any given time.

Type: number
Default: 100