Использование Lagom 1.4.11, Кафка 0.11 Связь с кафкой, кажется, работает, потому что продюсеры...

Мы определили базового подписчика, который пропускает пропущенные сообщения (т. Е. По некоторым...

У меня есть актер, который вызывает поток. Во время выполнения это работает как задумано, но при...

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

Я новичок в Scala и пытаюсь создать библиотеку, в которой я получу тысячи URL-адресов.Моя работа...

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

Какое значение по умолчанию для тайм-аута Ask в Akka? Все, что необходимо для использования метода...

Я создал удаленную среду для развертывания маршрутов, используя следующее: Маршрутизаторы с...

Я пытаюсь реализовать Java-версию примера "Up and Running" из книги Мэннинга "Akka in Action".Это...

В основном мне нужен актер, который использует функции Таймеры и Шкат . В Scala мы можем выполнить...

У меня есть локальный кластер кафки только одного брокера.У меня есть два потока akka: один поток...

В Akka я добавляю две разные машины в кластер.Но есть некоторые проблемы.Если 2 машины встают...

Я использую Kamon для сбора своих метрик и Datadog для их представления. в своем приложении...

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

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

Я пытаюсь переписать пример scala проекта POC из книги Мэннинга "Akka in Action" на Java.Проект...

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

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

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

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

У меня есть ParentActor и 2 ChildActors, вот мой код Class ParentActor extends Actor { val...

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

У меня есть следующий метод: private def initiateAuth(req: LoginRequest, userAgent: String,...

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

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