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

Моя настройка следующая: я извлекаю XML-файлы с ftp-сервера, распаковываю их в POJO, сопоставляю их...

У меня есть структура S3, которая является результатом задания Spark, которое записывает...

Я пытаюсь воссоздать пример прохождения для соединителя FTP-источника Alpakka с vsftpd server в...

У нас есть реализация сервера в akka-http на scala конечной точки Server Sent Events. Каждый запрос...

Я новичок в scala, использую клиент alpakka -asticsearch для выполнения запроса с эластичным...

Потребитель Alpakka kafka обрабатывает записи до тех пор, пока не обнаружит запись, которую он не...

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

У меня есть SchemaRegistry и KafkaBroker, из которого я беру данные с Avro v1.8.1. Для...

Я хотел бы использовать событие из темы Кафки, добавить его в базу данных, выполнить несколько...

Мы бы хотели использовать соединитель Alpakka Google Cloud PubSub https://doc.akka

Я использую https://doc.akka.io/docs/alpakka/current/mongodb.html API для связи с MongoDB следующим...

Я пытаюсь использовать https://doc.akka.io/docs/alpakka/current/mongodb.html как следующее: import...

Я пытаюсь вставить записи в зависимости от типа данных в mongodb с https://doc.akka

Я использую Alpakka и у меня есть пример игрушки ниже: val system = ActorSystem("system")...

Я использую соединитель alpakka для приема пакетов от Kafka и вставки их в базу данных Mongo. Я...

Я использую соединитель Alpakka kafka для приема пакетов от kafka. Я использую Consumer в качестве...

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

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

Я пытаюсь выяснить, как передать сообщения от потребителя Kafka, подписанного на несколько тем, на...

Я читал документацию по Альпакке. Читая пользовательский API Kafka, я наткнулся на...

При запуске источника подписки из библиотеки Alpakka PubSub я получил возможные закодированные...

У меня есть потребитель kafka, который выглядит следующим образом: import akka.actor.ActorSystem...

Я просматривал документацию для Consumer API для Kafka в Alpakka.Я наткнулся на этот кусок кода

Думая о переносе некоторого устаревшего JMS-кода в Alpakka, одним из широко используемых шаблонов в...