У меня есть кластер Akka с 2 узлами, и я развертываю его с использованием стратегии непрерывного...
У меня есть опыт работы в RxJava, и теперь я начинаю использовать Akka Streams. Когда мне нужно...
Я вижу, что есть настройка, называемая "роли", которую вы можете указать в конфигурации Akka
Я пробую Akka Persistance и столкнулся с проблемой одновременного доступа к одному и тому же...
Представьте, что у меня есть класс JobsEndpoint, который содержит класс JobSupervisor, который...
При тестировании какого-либо родительского актера было бы удобно, если бы какие-либо дочерние...
При попытке добавить постоянный модуль akka я получаю исключение сериализации.Любые указатели будут...
Я работаю с конфигурацией диспетчера / исполнителя Akka и хочу доказать себе, что сделанные мной...
У меня есть несколько идентичных приложений Scala Akka-HTTP, каждое из которых установлено на...
Я читал документацию по Альпакке. Читая пользовательский API Kafka, я наткнулся на...
Нужен Sink, который никогда не тянет, чтобы использовать в юнит-тестах. Уже есть такой или мне...
Я просматривал документацию для Consumer API для Kafka в Alpakka.Я наткнулся на этот кусок кода
Я пытаюсь запустить образец akka-quartz-scheduler, я получил akka-quickstart-java и создал новый...
Я пытаюсь добавить инструментарий к y актерам и наткнулся на это https://github
Поскольку akka - это инструментарий для построения моделей акторов, которые являются объектами,...
Думая о переносе некоторого устаревшего JMS-кода в Alpakka, одним из широко используемых шаблонов в...
Я использую одноэлементную функцию кластера akka, чтобы иметь один главный узел и несколько рабочих...
Я подключаю Alpakka JMS к теме Oracle AQ.Сообщение, отправленное из БД Oracle, имеет тип sql типа...
Я пытаюсь понять составной поток (из Sink и Source) с веб-сайта , и они представляют собой...
Есть ли способ заставить CircuitBreaker перейти в состояние Open без реальных сбоев в выполняемых...
Я занимаюсь прекращением действия актера в моей программе.Но в какой-то момент, когда задача актера...
Я вижу, например, исключение следующим образом: org.apache.kafka.common.errors
Я разрабатываю решение на основе модели актора, и я хотел бы нарисовать / представить...
Я пытаюсь внедрить HTTP-клиент в моем приложении Akka для использования стороннего API. Я пытаюсь...
Я хотел бы передать файл в поток, но на некотором промежуточном этапе я хотел бы обработать его,...