Connect

zmq4

Writes messages to a ZeroMQ socket.

  • Common

  • Advanced

output:
  label: ""
  zmq4:
    urls: [] # No default (required)
    bind: true
    socket_type: "" # No default (required)
output:
  label: ""
  zmq4:
    urls: [] # No default (required)
    bind: true
    socket_type: "" # No default (required)
    high_water_mark: 0
    poll_timeout: 5s

This component is available only in builds of Redpanda Connect that enable cgo. The standard release binaries, the Docker images, and the standard rpk connect plugin don’t include it. To use it, do one of the following:

  • Download the redpanda-connect-cgo_<version>_linux_amd64 archive from the GitHub releases page. This archive is available for Linux AMD64 only.

  • Build Redpanda Connect from source with CGO_ENABLED=1 go build -tags x_benthos_extra,timetzdata ./cmd/redpanda-connect. The build needs a C compiler.

The cgo archive and the source build both need the ZeroMQ library (libzmq), because they include the zmq4 components.

Fields

bind

Whether to bind to the URLs and wait for peers to connect, instead of connecting to them.

Type: bool

Default: true

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

socket_type

The socket type to connect as.

Type: string

Options: PUSH, PUB

urls[]

A list of ZeroMQ endpoints to connect to, or to bind when bind is true, using a transport such as tcp://, ipc://, or inproc://. If an item in the list contains commas, it is split into multiple endpoints.

Type: array<string>

# Examples:
urls:
  - "tcp://localhost:5556"