Reactive Integration with Akka Streams and Alpakka
summary
Shows a runnable Java pipeline using Akka Streams plus Alpakka connectors: a file tail source reads CSV lines, a Flow parses to a domain model, a GraphDSL partition sends odd IDs to an HTTP connection flow and even IDs to a Cassandra sink. Notes Alpakka has ~30 connectors versus Camel’s ~200, emphasizes nonblocking backpressure, materialized values and the materializer, and demonstrates the pipeline running continuously with correct routing to HTTP and Cassandra.
AI-written summary · about
chapters (17)
- 0:00Introduction and speaker info
- 1:17History of system integration
- 4:26Streaming data challenges
- 6:10Introducing Alpakka and Akka Streams
- 7:35Backpressure in stream processing
- 10:02Reactive Streams criteria
- 13:08Akka Streams graph basics
- 14:34Use case overview
- 15:15Building the pipeline source
- 18:28Transforming CSV data
- 20:37Defining HTTP and Cassandra sinks
- 25:34Connecting to Cassandra
- 29:23Partitioning logic
- 35:43Assembling the pipeline
- 37:49Running the demo
- 39:22Further resources and contributions
- 40:47Q&A session
related talks
01h 07mA Practical Introduction to Akka Streams
49mA Practical Introduction to Akka Streams
42mLearn you Akka Streams for great Good!
46mAkka Streams & Reactive Streams in action
34mRetrofit Your Java App with a Reactive Flow Pipeline
38mRetrofit your Java App with a Reactive Flow Pipeline
37mReactive Pipeline Talk
01h 31mReactive Streams / Akka Streams