Synadia Connect

NSQ

NAMERUNTIMETYPEVERSION
nsqwombatsourcelatest

Subscribe to an NSQ instance topic and channel.

The following metadata fields are added to each message:

  • nsq_attempts
  • nsq_id
  • nsq_nsqd_address
  • nsq_timestamp

Configuration

NameTypeOptionalSecretDescription
nsqd_tcp_addresses[]stringnonoA list of nsqd addresses to connect to.
lookupd_http_addresses[]stringnonoA list of nsqlookupd addresses to connect to.
tlstlsnonoCustom TLS settings can be used to override system defaults.
topicstringnonoThe topic to consume from.
channelstringnonoThe channel to consume from.
user_agentstringnonoA user agent to assume when connecting.
max_in_flightintyesnoThe maximum number of pending messages to consume at any given time. The value defaults to 100.
max_attemptsintyesnoThe maximum number of attempts to successfully consume a messages. The value defaults to 5.

TLS Configuration

NameTypeOptionalSecretDescription
enabledboolyesnoWhether custom TLS settings are enabled. The value defaults to false.
skip_cert_verifyboolyesnoWhether to skip server side certificate verification. The value defaults to false.
enable_renegotiationboolyesnoWhether to allow the remote server to repeatedly request renegotiation.
Enable this option if you're seeing the error message local error: tls: no renegotiation. The value defaults to false.
root_casstringyesyesAn optional root certificate authority to use.
This is a string, representing a certificate chain from the parent trusted root certificate,
to possible intermediate signing certificates, to the host certificate. The value defaults to "".
client_certs[]client_certsyesnoA list of client certificates to use. . The value defaults to [].
Previous
NATS KV