README.adoc

ZeroMQ Sink

The "zeromq" sink enables sending messages to a ZeroMQ socket.

Input

• byte[]

Output

Payload

N/A

Options

The zeromq sink has the following options:

See Spring Functions Catalog for configuration options.

Build

$ ./mvnw clean install -PgenerateApps
$ cd apps

You can find the corresponding binder based projects here. You can then cd into one of the folders and build it:

$ ./mvnw clean package

Examples

java -jar zeromq-sink.jar --zeromq.consumer.connectUrl=tcp://server:port --zeromq.consumer.topic=