Building Reactive Pipelines with Kotlin & Spring
summary
Demonstrates moving from blocking code to a reactive pipeline that actually runs: uses Project Reactor and the reactive streams API, binds through Spring Cloud Stream to RabbitMQ and Apache Kafka, implements supplier→function→consumer chains (source, processor, sink) with Flux/Mono, shows simple backpressure strategies (buffer vs drop), composes multiple functions into a single pipeline, and live-codes a working demo where messages flow and the chained transforms execute end-to-end.
AI-written summary · about
chapters (15)
- 0:00Intro
- 1:41Tomorrows Sessions
- 2:42Who am I
- 4:45New Book
- 5:28Scaling
- 11:32Spring Cloud Stream
- 15:00Reactive Programming
- 16:22Active Streams
- 16:49Interfaces
- 17:18Lets Code
- 17:31IT Crowd
- 17:55Spring Initializer
- 21:03Coffee Example
- 29:14Creating the Processor
- 33:24Creating the Sync
related talks
37mReactive Pipeline Talk
30mRetrofit Your Java App With a Reactive Flow Pipeline
31mBuilding Reactive Microservices with Kotlin & running on Kubernetes
38mRetrofit your Java App with a Reactive Flow Pipeline
27mRetrofit your Java App with a Reactive Flow
51mReactive Spring
53mRefactor to Reactive with Spring 5 and Project Reactor
54mFull-stack Reactive Kotlin with Project Reactor & Spring Boot 2