Küme düğümlerinde çalışan Akka Streams

Question

Akka Streams'in ölçekleme bölümünü anlamaya çalışıyorum, burada çeşitli yanıtlar gördüm, ancak yine de bu işlevin nasıl gerçekleştirildiğini anlayamıyorum.

Aktarımdan anladığımdan, akışla etkileşime geçmek için kullanılan ActorPublisher/Subscribers var, ancak aynı zamanda bunların uzak olamayacağını söylüyor.

Akka kümelerini akarsularla birlikte kullanmaya nasıl başlarım? GraphStage'ın çalışmalarını uzak bir aktöre "dış kaynak" yapmasına izin vermek zorunda mıyım? Veya graphStage'ın kendisi bir küme düğümünde çalıştırılabilir mi?

Kullanım durumumda, birleşmeler ve birleşmelerle birkaç ağır hesaplama aşaması içeren bir boru hattı var ve bu aşamalardan bazılarının dağıtılması gerekiyor.

Güncelleme
bu Crawling the Web with Akka Streams göre tek bir grafik birçok kümelenme yayılamaz görüyoruz. Bu durumda yatay olarak ölçeklemenin yolu ne olurdu?

Answer 1

akka-stream'ler kümelenmeyi henüz desteklemiyor. Bazı kümeleme çözümlerine ve reactive-kafka'a gereksinim duyuyorsanız, taşıma için middleware olarak Apache Kafka'a bakmanızı öneririm. Ama tabii ki, kendi taşıma katmanınızı aktörlerle uygulayabilir ve Akka kümesinde çalıştırabilirsiniz.