## Questions - Consume kinesis stream via an Akka stream? - Stream supervision? - Steam backpressure? - Mapping to Beam apps? - CQRS - RX java? - What's the equivalent of a buffered (blocking channel) in Akka, akka stream? - Channels vs Streams? - Akka using kotlin? - Alpakka? https://doc.akka.io/docs/alpakka/current/ - Alpaka vs rx java - Akka streams vs rx java vs kotlin flow ## References / Resources - Integrating Akka Streams and Akka Actors: Part I - https://blog.colinbreck.com/integrating-akka-streams-and-akka-actors-part-i - https://blog.colinbreck.com/integrating-akka-streams-and-akka-actors-part-ii - Actor as a sink - Send messages to a stream - Managing Streaming And Queryable State In Spark, Akka Streams, Kafka Streams, And Flink - (Design Techniques for Building Streaming Data, Cloud-Native Applications) - https://www.lightbend.com/blog/managing-streaming-and-queryable-state-in-spark-akka-streams-kafka-streams-flink - Building data pipelines with Kotlin using Kafka and Akka - https://www.kotlindevelopment.com/data-pipelines-kotlin-akka-kafka/