Я пытаюсь прочитать файл avro с Source из akka Streams. Источник в потоках akka читает данные,...

Моя текущая система имеет около 100 тысяч работающих графиков, каждый из которых построен так:...

База на Документация Akka : Если вы хотите убедиться, что ваши реквизиты являются сериализуемыми,...

У меня есть следующий код: val fsm = TestFSMRef(new SenderCollectorFsm) И не понимаю, почему я...

Вот мой код import akka.http.javadsl.Http // some initialization omitted inline fun <reified...

У меня есть механизм обмена сообщениями Akka, который доставляет миллионы сообщений в течение дня,...

Я пытаюсь выяснить, как обработать исключение с ошибочным сообщением Avro.В настоящее время я...

Я пытаюсь выяснить, как упаковать и развернуть мое приложение lagom в производстве. Документы...

Итак, у меня есть следующий тип: case class Episode( parentTconst: String, seasonNumber: Int,...

Я рассматриваю возможность использования Alpakka для обработки подписчиков на сервере MQTT, и я...

Я хотел бы передать универсальный класс, как показано в коде ниже, но я получаю исключение:...

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

У меня есть клиент websocket, который выглядит следующим образом: object Main extends App { private...

У меня есть требование получить данные из базы данных и создать файл данных CSV и вернуть его, и...

Я создал очень простой поток akka на основе проекта alpakka, но он ничего не читает из kafka, даже...

У меня есть одна из наших систем Python, генерирующая файлы Parquet с использованием Pandas и...

Я пытаюсь проверить, является ли тема, переданная моему методу "start stream", допустимой / уже...

У меня есть сервер Akka, который запрашивает файл молотка (некоторый вывод) у актера.Тем не менее,...

Я реализовал сервер веб-сокетов, используя Play Framework. Сервер может принимать соединения и...

Имеет два входных потока, каждый из которых создает экземпляры объектов, определенные как case...

У меня есть проект в акке и цирце. В настоящее время я отправляю этот json в теле ответа: {...

Я использую Akka HTTP и хотел бы регистрировать каждый входящий запрос и исходящий результат.Я знаю...

Я использую akka http и у меня вопрос по поводу конфигурации? Когда я хочу использовать...

Скажем, у меня есть сущность, которая содержит ссылку на свой дочерний актер в качестве одного из...

Я хочу иметь класс ActorFactory, как показано ниже public class SampleActorFactory { // Simple...