Keyboard shortcuts

Press or to navigate between chapters

Press S or / to search in the book

Press ? to show this help

Press Esc to hide this help

ZeroMQ

Schemes: zeromq://, zmq://

Query parameters recognised as config fields for this connector. Unrecognised parameters are not forwarded as driver options, so any other ?key=value pair is rejected rather than silently ignored.

NameTypeRequiredDefaultDescription
backendzmq | omqnozmqBackend: zmq (default, the zeromq crate) or omq (the omq-tokio PoC — PUSH/PULL + PUB/SUB only). omq needs the zeromq-omq build feature.
bindbooleannofalseIf true, bind to the address. If false, connect.
formatjson | raw | raw_framednojsonWire format: json wraps the CanonicalMessage; raw sends payload bytes per frame; raw_framed adds a JSON metadata frame. Default json.
internal_buffer_sizeintegernonullInternal buffer size for the channel. Defaults to 128.
socket_typepush | pull | pub | sub | req | repnonullThe socket type (PUSH, PULL, PUB, SUB, REQ, REP).
topicstringno(Consumer only) The ZeroMQ topic (for SUB sockets).
urlstringyesThe ZeroMQ URL (e.g., “tcp://127.0.0.1:5555”).