Retrofit your Java App with a Reactive Flow
summary
Demo retrofits a monolithic JVM workflow into a reactive pipeline using Kafka as source/sink, Akka Streams on the producer side, an RSocket link, and a Java consumer that publishes results back to Kafka. The pipeline enforces end-to-end backpressure control, so when the consumer sleeps five seconds the upstream pauses and resumes without loss; messages are produced at one per second during the demo. Code and Docker Compose are on GitHub. RSocket + Akka Streams
AI-written summary · about
chapters (9)
- 0:00Introduction
- 4:25Demo
- 10:10Code
- 15:13Agenda
- 15:48Traditional Enterprise
- 16:57Reactive Flow
- 19:11Reactive Solutions
- 21:03Building the Pipeline
- 24:36Conclusion
related talks
30mRetrofit Your Java App With a Reactive Flow Pipeline
38mRetrofit your Java App with a Reactive Flow Pipeline
34mRetrofit Your Java App with a Reactive Flow Pipeline
37mReactive Pipeline Talk
41mBuilding Reactive Pipelines with Kotlin & Spring
53mGetting into the Flow: building applications with Reactive Streams
01h 17mReacting to an Event-Driven World.
47mReactive Spring