Мы пытаемся использовать Akka Streams с Alpakka Kafka для потребления потока событий в сервисе.Для...

В потоках akka можно сделать следующее: Source.tick(0.seconds, 15.seconds, "Hello") И ваш...

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

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

Мне нужно вызвать cassandra для получения даты, а затем передать полученную дату другому потоку,...

Я запускаю один поток в качестве издателя с разветвлением, установленным в значение true. Теперь,...

У меня есть довольно простое приложение, которое состоит из потребителя Kafka, сидящего за...

Я использую slick в Akka Streams для загрузки большого количества записей (~ 2M) из базы данных...

Я использую последнюю версию akka 2.5.21 и akka-http 10.1.7 Мой WS-сервер выдает информационный...

Я использую стороннюю библиотеку для предоставления сервисов синтаксического анализа (в моем случае...

Я создал материализатор для потоков akka, используя собственную стратегию наблюдения:

Я изо всех сил пытаюсь реализовать - довольно простой - поток Akka.Вот что мне нужно: У меня есть...

Я работаю над исправлением, которое должно принять запрос SOAP XML, значение которого меньше 1 000...

Я хочу добиться интеграции между Akso Streams Websocket и Actor, который поддерживает...

Я пытаюсь выполнить следующий код в Scala с помощью akka-stream: case class User(xid: String, name:...

У меня есть следующий код, и я пытаюсь подключиться к потоку akka MysqlDatabase.У меня есть файл...

У меня проблемы с тем, что akka-http возвращает исключение, когда akka-поток завершается ошибкой во...

В настоящее время я пытаюсь создать соединение веб-сокета akka-http, которое может: транслировать...

Я пытаюсь выяснить, как Lagom можно использовать для получения данных из внешних систем,...

У меня есть Alpakka Elasticsearch Sink, который я храню между запросами.Когда я получаю запрос, я...

Я только начал использовать потоки akka, так что это может быть тривиальным вопросом, однако я не...

Способ слияния элементов akka-stream не очень прозрачен.Мне было интересно, если есть способ: Чтобы...

какой неявный параметр я должен добавить и как? Я уже пытался добавить: implicit val sz = Size; Но...

пытаясь понять документ groupBy, кажется, что его нужно переписать немного лучше.В то же время у...

Я хотел узнать сообщения об ошибках для моих производителей rabbitmq, используя некоторые функции...