zmq4
Consumes messages from a ZeroMQ socket.
- Common
- Advanced
# Common config fields, showing default valuesinput:label: ""zmq4:urls:- tcp://localhost:5555bind: falsesocket_type: PULLsub_filters: []
# All config fields, showing default valuesinput:label: ""zmq4:urls:- tcp://localhost:5555bind: falsesocket_type: PULLsub_filters: []high_water_mark: 0poll_timeout: 5s
ZMQ4 is supported but currently depends on C bindings. Since this is an annoyance when building or using Benthos it is not compiled by default.
There is a specific docker tag postfix -cgo
for C builds containing
ZMQ support.
You can also build it into your project by getting libzmq installed on your machine, then build with the tag:
go install -tags "ZMQ4" github.com/Jeffail/benthos/v3/cmd/benthos
ZMQ4 input supports PULL and SUB sockets only. If there is demand for other socket types then they can be added easily.
Fields​
urls
​
A list of URLs to connect to. If an item of the list contains commas it will be expanded into multiple URLs.
Type: array
Default: ["tcp://localhost:5555"]
bind
​
Whether to bind to the specified URLs or connect.
Type: bool
Default: false
socket_type
​
The socket type to connect as.
Type: string
Default: "PULL"
Options: PULL
, SUB
.
sub_filters
​
A list of subscription topic filters to use when consuming from a SUB socket. Specifying a single sub_filter of ''
will subscribe to everything.
Type: array
Default: []
high_water_mark
​
The message high water mark to use.
Type: int
Default: 0
poll_timeout
​
The poll timeout to use.
Type: string
Default: "5s"