Reactive Streams for ZeroMQ

A minimal Akka Streams library for implementing flows with ZeroMQ sockets, inspired by Reactive Kafka. Features:

• PUB socket sink
• SUB socket source
• PUSH socket sink
• PULL socket source

Internal communication is currently implemented using JeroMQ (a pure Java implementation of ZMQ).

Gatling Tests

A DSL for building ZeroMQ load tests is provided by the benchmarks module. To run sample tests:

sbt benchmarks/gatling-it:test