RabbitMQ Stream Plugin

This is a RabbitMQ plugin that exposes streams - append-only, FIFO structures - in a RabbitMQ broker/cluster, through a custom binary protocol.

This was migrated to https://github.com/rabbitmq/rabbitmq-server

This repository has been moved to the main unified RabbitMQ "monorepo", including all open issues. You can find the source under /deps/rabbitmq_stream. All issues have been transferred.

How to Use

See the stream Java client documentation to set up a node with the stream plugin.

The stream Java client is currently the best way to experiment with the plugin.

Stream Protocol

The plugin uses a custom binary protocol.

Project Maturity

The project is in early stages of development and is considered experimental. It is not ready for production use.

Support

For questions: RabbitMQ Users
For bugs and feature requests: GitHub Issues

The project is currently under development, there is no guarantee yet that it will be maintained and supported in the future (read: you are welcome to experiment with it and give feedback, but please do not base your whole business on it).

Build Instructions

git clone git@github.com:rabbitmq/rabbitmq-public-umbrella.git
cd rabbitmq-public-umbrella
make co
make up BRANCH="stream-queue" -j 32
cd deps
git clone git@github.com:rabbitmq/rabbitmq-stream.git rabbitmq_stream
cd rabbitmq_stream
make run-broker

Then follow the instructions to build the client and the performance tool.

Licensing

Released under the MPL 2.0.

rabbitmq/rabbitmq-stream