akka

5Ciepło

2Odpowiedz

Chcę stworzyć system, który nie będzie miał pojedynczego punktu awarii. Miałem wrażenie, że routery są narzędziem do robienia tego, ale nie jestem pewien, czy działa tak, jak bym się spodziewał. Jest

8Ciepło

2Odpowiedz

Jak korzystać z HTTP Akka do generowania treści przez strumień wyjściowy

Jestem całkiem początkującym dla Akka Streams i Akka HTTP. Chciałbym wygenerować prosty serwer HTTP, który może wygenerować plik zip z zawartości folderu i wysłać go do klienta. Plik org.zeroturnaroun

5Ciepło

1Odpowiedz

Co oznaczają parametry typu dla źródła <Out,Mat>?

Próbuję zrozumieć typ źródła dla strumieni Akka, określony here. Niestety, dokumentacja i przykłady, które znalazłem, nie wyjaśniają, co właściwie oznaczają poszczególne parametry. Zgaduję, że Out jes

6Ciepło

1Odpowiedz

Akka Cluster łączenie z równoważeniem obciążenia DNS

Patrząc na akka cluster documentation wydaje się, że musisz znać wartość portu serwera co najmniej 1 "węzeł początkowy", aby dołączyć do klastra. Przykład application.conf wyraźnie wskazuje, że dewelo

5Ciepło

1Odpowiedz

błąd kompilacji Akka http

Jestem nowy w środowisku akka, a teraz spróbuj skonfigurować prosty serwis z tą strukturą. napisać prostą aplikację Akka-http: import akka.actor.ActorSystem import akka.http.scaladsl.Http import akk

6Ciepło

1Odpowiedz

Akka Strumienie podzielony przez strumień typu

mam następujący prosty przypadek hierarchię klasy: sealed trait Message case class Foo(bar: Int) extends Message case class Baz(qux: String) extends Message i mam Flow[Message, Message, NotUsed] (

5Ciepło

1Odpowiedz

Jak mogę przetestować metodę odbioru Abonenta w Akka Cluster?

Mam następujący Subscriber abstrakcyjna klasa podstawowa: abstract class Subscriber(topics: Seq[String]) extends Actor with ActorLogging { import DistributedPubSubMediator.{ Subscribe, SubscribeA

5Ciepło

3Odpowiedz

Serwer proxy sieci Web korzystający z kanałów Play 2.6 i akka

Próbuję utworzyć prosty serwer proxy dla połączeń Websocket, używając strumieni Play i akka. przepływ ruchu jest tak: (Client) request -> -> request (Server) Proxy (Client) response <-

7Ciepło

1Odpowiedz

Kolizja wersji Akka między Flink i Play 2.5

W naszym projekcie mamy zadanie strumieniowania Flink (1.1.3), które czyta z jednej kolejki kafka, wykonuje transformację funkcji mapy i zapisuje do kolejnej kolejki. To działało dobrze, dopóki nie wp

11Ciepło

2Odpowiedz

Nieprzenikniony błąd spowodowany przez wyłączenie wątku maszyny JVM, ponieważ w systemie ActorSystem

jest włączony plik "akka.jvm-exit-on-fatal-error". W wierszu polecenia uruchomiono plik JAR i uzyskałem wyjątek poniżej. I w wyniku zakończenia. błąd Uncaught z nici [ccp-akka.persistence.dispatchers.