ZeroMQ Source Connector

stream sourcescan table source

The ZeroMQ source connector subscribes to ZeroMQ publishers and channels messages into the rekuiper stream processing engine.

Configuration Overview

Configure the connector in $rekuiper/etc/sources/zmq.yaml:

default:
  server: tcp://192.168.2.2:5563

test:
  server: tcp://127.0.0.1:5563

Configuration Parameters

• server: Target ZeroMQ publisher endpoint URL (such as tcp://127.0.0.1:5563).

Custom Configurations

Define custom configuration blocks in zmq.yaml to connect to distinct ZeroMQ endpoints:

test:
  server: tcp://127.0.0.1:5563

Reference the configuration using CONF_KEY="test":

CREATE STREAM demo () WITH (
  DATASOURCE = "demo",
  FORMAT = "JSON",
  CONF_KEY = "test",
  TYPE = "zmq"
);

In this definition, DATASOURCE specifies the ZeroMQ subscription topic.

For stream syntax and management details, refer to Streams Management.