Building Reactive Pipelines
summary
Shows how to move from HTTP microservices to reactive pipelines using Spring Cloud Stream with a RabbitMQ binder and Project Reactor primitives. Builds three apps (source/processor/sink), supplies a Flux via flux.interval(1s) that emits a generated Passenger, applies a processor that upgrades ~1-in-4 to PREMIUM (random.nextInt(4)==0), and a sink that logs. Demonstrates backpressure (drop strategy) and runs live — pipeline runs end-to-end in the demo.
AI-written summary · about
chapters (22)
- 0:00Intro
- 0:39When youre asked to do more with less
- 1:27Agenda
- 3:23Who am I
- 5:21Monoliths
- 12:33Spring Cloud Stream
- 18:08Decoupling
- 23:48Reactive Brain
- 28:03Reactive Streams
- 31:27Symmetry
- 32:23Homework
- 33:45Spring Initializer
- 39:05IDEs
- 41:57Color Scheme
- 42:40Server Port
- 44:32Do what you love
- 45:53Creating a class
- 49:33Generating a passenger
- 51:30Creating a supplier
- 52:38Creating a flux
- 53:20Creating a buffer
- 56:16Creating a gate agent
related talks
20mA Reactive Fraud Monitoring Engine for Instant Payments
01h 25mEmpower Your Projects with Prefect's Pipeline Magic
25mAccelerating Data Processing and Consumption for Building Modern Apps at the Edge
35mBuilding Robust Reactive ML Systems In A Multiplayer Setting
01h 47mRadanalytics.io streaming applications workshop
44mShaping the Future of Real-time Data Pipeline
43mSimplifying Real-Time ML Pipelines with Quix Streams: An Open Source Python Library for ML Engineers
39mIntroducing Spring for Apache Pulsar