Akka Потоки, запущенные на узлах кластера

Question

Я пытаюсь понять масштабирующую часть потоков Akka. Здесь я вижу различные ответы, но все еще не понимаю, как эта функциональность выполнена.

Есть ActorPublisher/Подписчики, которые из того, что я понимаю, предназначены для взаимодействия с потоком, но в то же время говорят, что они не могут быть удаленными.

Как бы я смог использовать akka clusters toegether с потоками? Должен ли я предоставить GraphStage «аутсорсинг» своей работы удаленному игроку? Или может ли сам graphStage запускаться на узле кластера?

В моем примере использования имеется трубопровод, содержащий несколько тяжелых этапов расчета с соединениями и слияниями, и, возможно, некоторые из этих этапов должны быть распределены.

Обновление
Согласно этому Crawling the Web with Akka Streams я вижу, что один граф не может охватывать несколько кластеров. Каким будет в этом случае горизонтальный масштаб?

Answer 1

akka-streams еще не поддерживает кластеризацию. Я предлагаю посмотреть на Apache Kafka в качестве промежуточного программного обеспечения для транспорта, если вам нужно некоторое решение для кластеризации, и reactive-kafka. Но, конечно, вы можете реализовать свой собственный транспортный уровень с актерами и запустить его в кластере Akka.