Stream Core vs Stream Plugin


This section covers the differences between stream core and the stream plugin. Stream core designates stream features in the broker with only default plugins activated and through protocols like AMQP 0.9.1, MQTT, and STOMP.

Feature Matrix

Feature Stream Core Stream Plugin
Activation Built-in Must be activated
Protocol AMQP 0.9.1 RabbitMQ Stream
Clients AMQP 0.9.1 clients (documentation) RabbitMQ stream clients
Port 5672 5552
Format Server-side AMQP 1.0 message format encoding and decoding Client-side AMQP 1.0 message format encoding and decoding
Sub-entry batching Not supported Supported (Java example)
Offset tracking Use external store Built-in server-side support (Java example) or external store
Publishing deduplication Not supported Supported (Java example)
Super stream Not supported Supported
Throughput Hundreds of thousands per second Millions messages per second
TLS Supported (default port: 5671) Supported (default port: 5551)


Streams store messages using the AMQP 1.0 message format.

  • RabbitMQ Stream client libraries are expected to support the AMQP 1.0 message format
  • The broker handles the conversion between AMQP 1.0 and AMQP 0.9.1 for AMQP 0.9.1 clients
  • AMQP 0.9.1 and stream clients can write to and read from the same stream, but Sub-Entry Batching is not supported.
  • RabbitMQ Stream supports the following section of the AMQP 1.0 message format:
    • properties
    • application properties
    • application data
    • message annotations

Getting Help and Providing Feedback

If you have questions about the contents of this guide or any other topic related to RabbitMQ, don't hesitate to ask them using GitHub Discussions or our community Discord server.

Help Us Improve the Docs <3

If you'd like to contribute an improvement to the site, its source is available on GitHub. Simply fork the repository and submit a pull request. Thank you!