Я пытаюсь использовать сообщения от Kafka, используя реактивную библиотеку kkka. Я получаю одно сообщение распечатана и после этого я получил [INFO] [01/24/2017 10:36:52.934] [CommittableSourceConsume
В приведенном ниже коде успешно устанавливается соединение с веб-разъемом. Сервер websockets (также akk-http) намеренно закрывает соединение, используя Andrew's suggested answer here. SinkActor ниже п
Я довольно новичок в потоке Akka, я некоторое время работал с Rx, поэтому знаю довольно хорошо всех операторов, но я не могу понять, почему мой конвейер не испускает значения Вот мой код @Test def mai