In this chapter, we will discuss the use of the Akka Streams API to easily perform asynchronous data stream processing with non-blocking backpressure. We will also discuss what the CQRS/ES pattern is and how the Akka Persistence module uses this pattern to support the development of Event-Driven systems or applications.
Its shares the same Akka Toolkit office website (http://akka.io/) and GitHub source code location is available at https://github.com/akka/akka.
In this chapter, you will learn the following concepts:
- Streams and the benefits of streaming data
- Akka Streams and their features and benefits
- How Akka Streams support data streaming
- Backpressure and its importance
- How Akka Streams implements backpressure, and why we need it in data streaming
- Akka Streams API examples
- How to use the Akka Streams GraphDSL API
- Akka Persistence and its features...
