Мы пытаемся использовать 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, используя некоторые функции...