Connect
Self-Managed Only

nanomsg

Consumes messages via Nanomsg sockets (scalability protocols).

Currently only PULL and SUB sockets are supported.

  • Common

  • Advanced

input:
  label: ""
  nanomsg:
    urls: [] # No default (required)
    bind: true
    socket_type: PULL
    auto_replay_nacks: true
    sub_filters: []
input:
  label: ""
  nanomsg:
    urls: [] # No default (required)
    bind: true
    socket_type: PULL
    auto_replay_nacks: true
    sub_filters: []
    poll_timeout: 5s

Fields

auto_replay_nacks

Whether to automatically replay rejected messages (negative acknowledgements, or nacks) at the output level. If the cause of rejections persists, leaving this option enabled can result in back pressure.

Set auto_replay_nacks to false to delete rejected messages. Disabling auto replays can greatly improve memory efficiency of high throughput streams, as the original shape of the data is discarded immediately upon consumption and mutation.

Requires version 4.27.0 or later.

Type: bool

Default: true

bind

Whether the URLs provided should be connected to, or bound as.

Type: bool

Default: true

poll_timeout

The period to wait until a poll is abandoned and reattempted.

Type: string

Default: 5s

socket_type

The socket type to use.

Type: string

Default: PULL

Options: PULL, SUB

sub_filters[]

A list of topic prefixes to subscribe to when socket_type is SUB. A message is received only when its body starts with one of the prefixes, so a single empty filter ('') subscribes to everything. A SUB socket requires at least one filter.

Type: array<string>

Default: []

urls[]

A list of URLs to connect to, or to listen on when bind is true. If an item in the list contains commas, it is split into multiple URLs. A host, such as tcp://:5555, is replaced with 0.0.0.0.

Type: array<string>