Akka   Akka Streams & Alpakka


About the Akka Streams & Alpakka category (1)
Throttle stream based on external input (4)
Stateful subscription using streams (5)
Restart sources (4)
Ask vs Tell or forward for Actors using Akka Streems (1)
Run stream of elements through substream dynamic per element (3)
Akka Streams - Kafka offset reset after partition reassignment (2)
How to do parameterized query using slick (2)
How to shutdown a stream prefixed with a MergeHub.source without loosing elements (1)
Alpakka Kafka 1.0-M1 released (1)
The idiomatic way to manage shared state with Akka Streams (5)
Facilitating adoption: open-source security assessment (5)
Alpakka S3: Retrying internal errors (3)
Passing stream elements "into" AND "over" flow (7)
Integrating an Observable within a FlowShape (4)
Acknowledging PING from Server in the middle of a stream (7)
[Kafka] "The coordinator is not aware of this member. from time to time in my logs" error (1)
Running into AbruptIOTerminationException with idleTimeout usage (4)
Should we use Akka Stream and actors vs Spark Streaming? (2)
Collapsing a stream of updates/appends when the consumer is slow (4)
Question about some of the documentation in akka streams (9)
Taking a function and turning it into a sink? (6)
Alpakka amqp Synchronous rpc (3)
Forking a flow based on a boolean condition (2)
Alpakka Google Pub Sub (2)
Losing console output with use of subflows (4)
Infinite Streaming from Cassandra (5)
HicariCP connection pool seems not to work properly with alpakka-slick (2)
AkkaStream. Proper flow decomposition (5)
Handling SerializationException in an Alpakka Kafka consumer (2)