nanomsg
Type:
Consumes messages via Nanomsg sockets (scalability protocols).
-
Common
-
Advanced
# Common config fields, showing default values
input:
label: ""
nanomsg:
urls: [] # No default (required)
bind: true
socket_type: PULL
auto_replay_nacks: true
sub_filters: []
# All config fields, showing default values
input:
label: ""
nanomsg:
urls: [] # No default (required)
bind: true
socket_type: PULL
auto_replay_nacks: true
sub_filters: []
poll_timeout: 5s
Currently only PULL and SUB sockets are supported.
Fields
urls
A list of URLs to connect to (or as). If an item of the list contains commas it will be expanded into multiple URLs.
Type: array
auto_replay_nacks
Whether messages that are rejected (nacked) at the output level should be automatically replayed indefinitely, eventually resulting in back pressure if the cause of the rejections is persistent. If set to false
these messages will instead be deleted. Disabling auto replays can greatly improve memory efficiency of high throughput streams as the original shape of the data can be discarded immediately upon consumption and mutation.
Type: bool
Default: true
Was this helpful?