Akka   Akka Streams & Alpakka


About the Akka Streams & Alpakka category (1)
IllegalArgumentException committing offsets: origin stage must be same as other stage with same groupId (3)
Mutual TLS implementation for Akka Http Client and Akka Http Server or Other Server (1)
Is it possible to cancel outstanding futures in mapAsync on stream failure? (8)
Increasing consumers in consumer group cause rebalance failure with CommitFailedException because of revoked partition (2)
Alpakka 1.0-RC1 is now available! (1)
AKKA Stream mapAsync doesn't return elements by order (2)
Reading messages from AWS SQS in Java (1)
Akka streaming broadcast (1)
Newbie question about Alpakka S3 (2)
Alpakka Kafka 1.0.1 is available now (1)
Alpakka 1.0-M3 released (1)
UnixDomainSocket causing "Substream Source cannot be materialized more than once" (5)
Alpakka-MQTT not subscribing (9)
Alpakka AMQP Consuming (5)
Java examples for Kafka consumer (4)
Akka.test.single-expect-default must be higher than 5s (5)
Alpakka Kafka 1.0-RC2 released (1)
In order merge after groupBy (3)
How are Akka streams implemented on top of Akka actors? (2)
Creating new bucket in Alpakka (2)
Alpakka FTP recursive listing of directory tree (5)
Clarifying GroupBy Documentation (2)
Inject a producer using ProducerSettings (3)
Alpakka Spring Web support for setting the ActorSystem name (5)
Timeout handling in Alpakka S3 (3)
Why TransactionalSource needs isolation.level to be read_committed? (4)
Problem applying custom S3Settings (8)
Announce: Trembita 0.8.0-SNAPSHOT is out! (1)
Is it possible to share KafkaConsumerActor in Consumer.committableSource? (3)