Skip to main content

zmq4

Consumes messages from a ZeroMQ socket.

# Common config fields, showing default values
input:
label: ""
zmq4:
urls: []
bind: false
socket_type: ""
sub_filters: []

By default Bento does not build with components that require linking to external libraries. If you wish to build Bento locally with this component then set the build tag x_bento_extra:

# With go
go install -tags "x_bento_extra" github.com/warpstreamlabs/bento/cmd/bento@latest

# Using make
make TAGS=x_bento_extra

There is a specific docker tag postfix -cgo for C builds containing this component.

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

# Examples

urls:
- tcp://localhost:5555

bind

Whether to bind to the specified URLs (otherwise they are connected to).

Type: bool
Default: false

socket_type

The socket type to connect as.

Type: string
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"