Streaming RabbitMQ

This repository is an example of how streaming works in RabbitMQ in Go.

Requirements

You will need an rabbitMQ with Advertised server settings and enabled Streaming plugin

docker run -d --name rabbitmq -p 5552:5552 -p 5672:5672 -p 15672:15672 -e RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS='-rabbitmq_stream advertised_host localhost -rabbit loopback_users "none"' rabbitmq:3.9-management

docker exec rabbitmq rabbitmq-plugins enable rabbitmq_stream # Enable Stream plugin
docker exec rabbitmq rabbitmq-plugins enable rabbitmq_stream_management # Enable UI to manage streams

Appendix

Stream feature matrix RabbitMQCTL RabbitMQ Consumption RabbitMQ Data safety SuperStreams