# Akka Streams

**URL:** https://forum.ficusonline.com/t/topic/392
**Category:** Programming
**Created:** [2020 年 10 月 30 日午前 2:40 UTC](https://forum.ficusonline.com/t/topic/392 "2020-10-30T02:40:33Z")
**Posts on this page:** 8
**Page:** 1

<div class="post-metadata">

### Author: ![tk-fuse](https://forum.ficusonline.com/user_avatar/forum.ficusonline.com/tk-fuse/32/255_2.png) [@tk-fuse](https://forum.ficusonline.com/u/tk-fuse)
#### Post date: [2020 年 10 月 30 日午前 2:40 UTC](https://forum.ficusonline.com/t/topic/392/1 "2020-10-30T02:40:33Z")

</div>

**リファレンス**  
[https://doc.akka.io/docs/akka/current/stream/index.html](https://doc.akka.io/docs/akka/current/stream/index.html)

**Scala API**

> **[Akka 2.10.11 - akka.stream](https://doc.akka.io/api/akka-core/current//akka/stream/index.html)**
>
> Akka 2.10.11 - akka.stream

---

<div class="post-metadata">

### Author: ![tk-fuse](https://forum.ficusonline.com/user_avatar/forum.ficusonline.com/tk-fuse/32/255_2.png) [@tk-fuse](https://forum.ficusonline.com/u/tk-fuse)
#### Post date: [2020 年 11 月 26 日午前 5:43 UTC](https://forum.ficusonline.com/t/topic/392/2 "2020-11-26T05:43:05Z")

</div>

> **[Streams Quickstart Guide • Akka core](https://doc.akka.io/libraries/akka-core/current/stream/stream-quickstart.html)**
>
> Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala.

> **[IDE Tips • Akka core](https://doc.akka.io/libraries/akka-core/current/additional/ide.html)**
>
> Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala.

AKKA StreamsにおけるJavaとScalaのDSLは同じJARファイルで纏められているため、IntelliJのjavadslの自動インポートは無効にすること。

 ![settings-autoimport-exclude-java](https://forum.ficusonline.com/uploads/default/original/1X/e1b441bd3a192f0114ef3842c72470e6d6b415e9.png)

---

<div class="post-metadata">

### Author: ![tk-fuse](https://forum.ficusonline.com/user_avatar/forum.ficusonline.com/tk-fuse/32/255_2.png) [@tk-fuse](https://forum.ficusonline.com/u/tk-fuse)
#### Post date: [2020 年 12 月 17 日午前 2:47 UTC](https://forum.ficusonline.com/t/topic/392/3 "2020-12-17T02:47:23Z")

</div>

### [How to Create Akka Streams of Any Shape Using the Graph DSL](https://www.youtube.com/watch?v=8XLB28KDtgg)

> **[Use Akka Streams' Graph DSL: Quickly Explained](https://rockthejvm.com/articles/akka-streams-graphs)**
>
> Explore Akka Streams' powerful Graph DSL and learn how to get started quickly with our easy guide

* * *

### [Comparing Kafka Streams, Akka Streams and Spark Streaming: what to use when](https://youtu.be/UaSXx-oObf4)

[https://blog.rockthejvm.com/kafka,-akka,-spark/](https://blog.rockthejvm.com/kafka,-akka,-spark/)

* * *

**Akka Streams** is best for high-performance systems, when you want to bake Akka Streams into your application. It has an extremely powerful API, but unless you know what you’re doing, it might be easy to shoot yourself (accidentally or not).

**Kafka** on the other hand works best as an external high performance message bus for your applications, so if you want microservices to read and write to and from a common event store, you might be best with Kafka. However, its Java-style API is cumbersome, but I understand it might be a matter of code cleanliness and taste.

Finally, **Spark Streaming** is without a doubt best for big data computation. Spark has always been good at that and here we also removed data bounds. However, at the moment of this recording, Spark Streaming is bad for actual application logic and low-latency, so you might want to use it as a data aggregator to gather insights from your data.

* * *

### [Materialized Values in Akka Streams](https://youtu.be/2-CK76cPB9s)

> **[The Brilliance of Materialized Values in Akka Streams](https://rockthejvm.com/articles/the-brilliance-of-materialized-values)**
>
> Demystify one of the hardest concepts in Akka Streams: materialized values made simple

---

<div class="post-metadata">

### Author: ![tk-fuse](https://forum.ficusonline.com/user_avatar/forum.ficusonline.com/tk-fuse/32/255_2.png) [@tk-fuse](https://forum.ficusonline.com/u/tk-fuse)
#### Post date: [2020 年 12 月 18 日午前 4:29 UTC](https://forum.ficusonline.com/t/topic/392/4 "2020-12-18T04:29:03Z")

</div>

### ActorMaterializer depricated

**Akka 2.6.10** : `ActorMaterializer--->Materializer`

> **[Akka 2.10.17 - akka.stream.ActorMaterializer](https://doc.akka.io/api/akka-core/current//akka/stream/ActorMaterializer.html)**
>
> Akka 2.10.17 - akka.stream.ActorMaterializer

> **[Akka 2.10.17 - akka.stream.Materializer](https://doc.akka.io/api/akka-core/current//akka/stream/Materializer.html)**
>
> Akka 2.10.17 - akka.stream.Materializer

> <https://stackoverflow.com/questions/64872825/akka-stream-2-6-0-deprecated-actor-system-setup>

---

<div class="post-metadata">

### Author: ![tk-fuse](https://forum.ficusonline.com/user_avatar/forum.ficusonline.com/tk-fuse/32/255_2.png) [@tk-fuse](https://forum.ficusonline.com/u/tk-fuse)
#### Post date: [2020 年 12 月 19 日午前 8:37 UTC](https://forum.ficusonline.com/t/topic/392/5 "2020-12-19T08:37:28Z")

</div>

> **[Chapter 13. Streaming · Akka in Action](https://livebook.manning.com/book/akka-in-action/chapter-13/1)**
>
> Processing streams of events in bounded memory · Streaming events over HTTP with akka-http · Broadcasting and merging with the graph DSL · Mediating between streaming producers and consumers

 ![log-streams](https://forum.ficusonline.com/uploads/default/original/1X/6d9161476dc82a30af5ea31670dbb82ffa89f1ad.jpeg)

**Log-streamサンプルコード**

> **[akka-in-action/chapter-stream at master · capitalfuse/akka-in-action](https://github.com/capitalfuse/akka-in-action/tree/master/chapter-stream)**
>
> Accompanying source code for akka in action . Contribute to capitalfuse/akka-in-action development by creating an account on GitHub.

**変更（修正）箇所リスト** （リモートのサンプルのコード変更が一部混在）  
SDKバージョンが古いため、最新バージョン変更に伴うコード修正

> <https://github.com/capitalfuse/akka-in-action/commit/a2709da6772d55d74e575baf3a989800d61b5870>

---

<div class="post-metadata">

### Author: ![tk-fuse](https://forum.ficusonline.com/user_avatar/forum.ficusonline.com/tk-fuse/32/255_2.png) [@tk-fuse](https://forum.ficusonline.com/u/tk-fuse)
#### Post date: [2020 年 12 月 19 日午後 2:22 UTC](https://forum.ficusonline.com/t/topic/392/6 "2020-12-19T14:22:43Z")

</div>

### Akka Stream Operators

> **[Operators • Akka core](https://doc.akka.io/libraries/akka-core/current/stream/operators/index.html)**
>
> Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala.

---

<div class="post-metadata">

### Author: ![tk-fuse](https://forum.ficusonline.com/user_avatar/forum.ficusonline.com/tk-fuse/32/255_2.png) [@tk-fuse](https://forum.ficusonline.com/u/tk-fuse)
#### Post date: [2020 年 12 月 22 日午前 2:33 UTC](https://forum.ficusonline.com/t/topic/392/7 "2020-12-22T02:33:41Z")

</div>

### Apache Camel or Alpakka Endpoints

> **[Apache Camel • Alpakka Documentation](https://doc.akka.io/libraries/alpakka/current/external/apache-camel.html)**
>
> Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

**Apache Camel** は **Akka Stream** に以下のライブラリで統合

> **[GitHub - krasserm/streamz: A combinator library for integrating Functional...](https://github.com/krasserm/streamz)**
>
> A combinator library for integrating Functional Streams for Scala (FS2), Akka Streams and Apache Camel

**Apache Camel**

> **[What is Camel?](https://camel.apache.org/manual/faq/what-is-camel.html)**
>
> Camel is an open source integration framework that empowers you to quickly and easily integrate various systems consuming or producing data.

**Alpakka sample code**

> **[GitHub - akka/alpakka-samples: Example projects building Reactive Integrations...](https://github.com/akka/alpakka-samples)**
>
> Example projects building Reactive Integrations using Alpakka

---

<div class="post-metadata">

### Author: ![tk-fuse](https://forum.ficusonline.com/user_avatar/forum.ficusonline.com/tk-fuse/32/255_2.png) [@tk-fuse](https://forum.ficusonline.com/u/tk-fuse)
#### Post date: [2020 年 12 月 29 日午前 9:52 UTC](https://forum.ficusonline.com/t/topic/392/8 "2020-12-29T09:52:20Z")

</div>

### Materialized, NotUsed

> **[Akka Streams – What is NotUsed all about](https://manuel.bernhardt.io/2017/05/22/akka-streams-notused/)**
>
> Akka Streams is a powerful implementation on top of the Reactive Streams SPI for non-blocking asynchronous communication with back-pressure on the JVM. This post is not about explaining what this means, nor what Akka Streams does. The purpose of this...

### Keep.left, Keep.right, Keep.both

> **[Modularity, Composition and Hierarchy • Akka core](https://doc.akka.io/libraries/akka-core/current/stream/stream-composition.html?language=scala)**
>
> Akka is a toolkit for building highly concurrent, distributed, and resilient message-driven applications for Java and Scala.
