Я пытаюсь вставить записи в зависимости от типа данных в mongodb с https://doc.akka
Я пытаюсь добавить аннотацию (newrelic для трассировки) к persistantActor receiveCommand в scala....
Ниже приведена трассировка ошибок, которую я получил при добавлении slf4j в мой проект Akka. ........
Я не могу настроить правильный Logger в типизированном актере. Это строка журнала, которую я хочу...
У меня странное поведение на моем проекте Акка.Подводя итог: у меня есть две Actorsystems,...
Я использую Alpakka и у меня есть пример игрушки ниже: val system = ActorSystem("system")...
В моем приложении есть источник, который я мультиплексирую для вызовов клиентов. Что-то вроде: val...
Я использую соединитель alpakka для приема пакетов от Kafka и вставки их в базу данных Mongo. Я...
Я пытаюсь сделать API Rest с помощью Akka. Одна из точек входа вернет данные из моей базы данных...
Я использую сервер grpc за AWS NLB. NLB завершает SSL, и соединение работает с клиентом go. Однако...
Я создал соединение клиент-сервер с использованием потоков akka со следующим кодом: val connection...
У меня есть доменный объект типа Person, который определяется в классе case следующим образом: case...
У меня есть java jar, который генерирует поток tcp на конкретном порту. Я могу запустить команду...
Допустим, у нас есть график, который выглядит следующим образом: broadcast ~> flowA ~> fanIn...
Я создал производителя akka kafka, мне нужно подключить его к брокеру kafka с использованием...
Я бы хотел измерить пропускную способность и время, необходимое для обработки пакета миллионов...
У меня проблемы с настройкой входа в систему с помощью Akka. В моем STDOUT это не скрывает их...
Я хочу использовать Guice Dependency Injection с Akka Actors. Документация Akka, здесь , предлагает...
У меня есть актер, соединяющийся с базой данных. Когда актер вызывается в огне и забывает модель из...
Я пытаюсь перенести проект, который был построен на jdk8, используя play и инфраструктуру Akka, на...
Итак, у меня есть небольшая пользовательская сцена для разделения в Akka Streams. object...
Я хочу заменить одну часть моего потокового процессора Akka Streams на Flink. Возможно ли в...
При запуске источника подписки из библиотеки Alpakka PubSub я получил возможные закодированные...
Я хотел бы выдать исключение следующим образом: Source.empty .map { throw new...
Пытаясь настроить ETag для веб-сервера, я получаю StackOverflowError при сравнении EntityTag...