Retrofit Your Java App With a Reactive Flow Pipeline

on YouTube ↗30m

" summary

Demo builds a reactive pipeline that wraps two legacy processors as microservices and connects them with Akka Streams -> RSocket -> Kafka. Code runs in Docker compose, first processor consumes a Kafka topic and only reads more when the downstream processor signals demand, proving backpressure works end-to-end during randomized processing delays. Repository and working example are provided; caveats include sparse RSocket docs and the Java side’s reliance on Project Reactor.

AI-written summary · about

" chapters (6)

1. 0:00Introduction to reactive pipelines
2. 4:40Reactive systems and microservices
3. 7:28Legacy processor pipeline demo
4. 18:13Running the demo step-by-step
5. 22:55Conclusions and lessons learned
6. 26:47Project Loom and reactive future

" related talks

• 27mRetrofit your Java App with a Reactive FlowMary Grygleski, Fabio Tiriticco · Scale By the Bay 2021
• 34mRetrofit Your Java App with a Reactive Flow PipelineMary Grygleski, Fabio Tiriticco · Berlin Buzzwords 2021
• 41mBuilding Reactive Pipelines with Kotlin & SpringMark Heckler · KotlinConf 2019
• 47mReactive SpringJosh Long · QCon São Paulo 2019
• 53mGetting into the Flow: building applications with Reactive StreamsTim van Eijndhoven · J-Fall 2018
• 24mBringing Reactive Programming to Java and MicroservicesLakshmi Menon · Developer Summit 2020
• 49mReactive SpringJosh Long · Build Stuff 2020
• 01h 01mThirst Quenching Streams for the Reactive MindMary Grygleski · Global Summit for Java Devs 2020