Retrofit your Java App with a Reactive Flow Pipeline

on YouTube ↗38m

" summary

Shows how to wrap two legacy processors — one Scala using Akka Streams, one Java exposing an RSocket server — with Kafka topics to form a reactive flow pipeline. Demo publishes one message/sec, some items take 5s to process, and backpressure propagates upstream so the first processor stalls until the slow item finishes. Code uses Kafka, Akka, RSocket and Reactor; demo successfully proves a thin reactive shell protects slow legacy services while noting RSocket/Java integrations and Reactor idioms are still rough.

AI-written summary · about

" chapters (18)

1. 0:00Introduction
2. 1:07Agenda
3. 2:21Fabios introduction
4. 3:09Fabio introduction
5. 4:00Why Reactive
6. 6:39Complex Systems
7. 7:48Reactive Systems
8. 11:34Test Case
9. 11:51Reactive Pipeline
10. 13:57Legacy Processor
11. 18:30Demo
12. 22:39Experience
13. 24:53Our Socket
14. 27:22Conclusion
15. 29:52Serverless
16. 31:07Project Loom
17. 33:26Will Project Loom replace Reactive
18. 34:48Resources

" 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
• 37mReactive Pipeline TalkMary Grygleski, Fabio Tiriticco · Devnexus 2021
• 41mBuilding Reactive Pipelines with Kotlin & SpringMark Heckler · KotlinConf 2019
• 53mGetting into the Flow: building applications with Reactive StreamsTim van Eijndhoven · J-Fall 2018
• 47mReactive SpringJosh Long · QCon São Paulo 2019
• 01h 01mThirst Quenching Streams for the Reactive MindMary Grygleski · Global Summit for Java Devs 2020
• 56mThirst-quenching Streams for the Reactive MindMary Grygleski · Developer Summit 2020