A minimal Akka Streams library for implementing flows with ZeroMQ sockets.
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
benchmarks/src
core/src
examples/src/main
project
stream/src
.gitignore
.travis.yml
LICENSE
README.md
build.sbt

README.md

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