What RabbitMQ Stream Can Do for Your Spring Applications
summary
RabbitMQ adds a log-style stream type with non-destructive consumer semantics, persistent replicated storage, server-side offset tracking and retention, publish confirms and deduplication, TLS, and a native stream protocol that benchmarks at over a million messages/sec (AMQP falls to ~64k). Java support includes a Stream client plus Spring integration: Spring AMQP template for publishing, @RabbitListener for consumption, Spring Integration adapters and a Spring Cloud Stream binder. Features include client-side partitioning via super‑streams and continuity via single active consumer.
AI-written summary · about
chapters (23)
- 0:00Introduction and overview
- 1:11What are RabbitMQ streams
- 3:22Why use streams instead of queues
- 4:05How queues work in RabbitMQ
- 6:33Stream data structure explained
- 9:07Stream replication and topology
- 11:41Creating and using streams
- 12:01Stream performance benchmarks
- 13:49Stream protocol advantages
- 15:38Using streams with protocols
- 17:04Real-world stream use case
- 18:48Guarantees and features of streams
- 21:35Single Active Consumer feature
- 23:28Super streams for scaling
- 26:20Stream Java client basics
- 28:53Spring AMQP integration
- 30:58Spring Boot setup
- 31:21Publishing with Spring AMQP
- 32:25Consuming with RabbitListener
- 33:53Spring Integration support
- 34:35Spring Cloud Stream integration
- 35:23Summary and key takeaways
- 36:27Q&A session
related talks
48mSpring for Rabbit Super Stream and SQL filters
01h 15mApplied Spring Integration, Spring AMQP and RabbitMQ in Spring XD
51mSpring Cloud Stream: Developer Recipes, Tips and Tricks
01h 12mCloud Event Driven Architectures with Spring Cloud Stream 2.0
31mWhat's New in Spring AMQP 2.0 - Gary Russell
59mGame of Streams: How to Tame & Get the Most from your Messaging Platforms
51mEvent Driven with Spring
30mA love letter to messaging: Celebrating RabbitMQ's journey