ZeroMQ

ZeroMQ is a high-performance asynchronous messaging library built around brokerless socket patterns (PUSH/PULL, PUB/SUB, REQ/REP).

omniload consumes from ZeroMQ via mq-bridge.

URI format

zeromq+mqb://localhost:5555?socket_type=pull

--source-table supplies the topic (the SUB filter, for pub/sub sockets). Common options: socket_type (pull/sub/rep/…), bind (bind vs connect), internal_buffer_size. The tcp:// scheme is assumed; pass ?url=ipc://… to override. See mq-bridge for the full option reference and delivery semantics.

Sample command

omniload ingest \
    --source-uri 'zeromq+mqb://localhost:5555?socket_type=pull' \
    --source-table 'events' \
    --dest-uri 'duckdb:///zeromq.duckdb' \
    --dest-table 'dest.events'