Я создал тему lagom в моем сервисе. def addingsTopic(): Topic[ProcessDefinitionAdded] дескриптор:...

У меня есть Source, который предоставляет элементы типа A. И у меня есть Flow, который получает...

Мы используем Kafka и надеемся использовать интерактивные запросы , чтобы получить доступ к данным...

У меня есть приложение, написанное на Scala / Akka и пытающееся добавить поддержку SOAP.Кто-нибудь...

У меня есть график, который считывает строки из нескольких сжатых файлов и записывает эти строки в...

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

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

Я немного поиграл с пакетом расширения streams для Akka.Net и заметил эту ошибку при попытке...

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

Я начинаю с Akka Streams, и я хотел бы создать сервер как Stream, который получает Http

Я впервые пробую AKKA-Http в Java (akka-http_2.12 v 10.1.5, akka-stream_2.12 v 2.5.17), но не могу...

Я уже некоторое время работаю с akka-актерами и akka-cluster.Недавно у меня было требование...

Я использую Kryo 5.0.0-RC1.У меня есть следующее исключение: java.lang.IndexOutOfBoundsException:...

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

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

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

Мы транслируем файл из S3 и обрабатываем его, после завершения процесса мы загружаем файл обратно в...

Я использую HTTP-клиент Akka для подключения к бесконечной потоковой конечной точке HTTP.У меня...

Попытка использовать Google CloudVision images.annotate с Akka-HTTP, изображения, поступающие в...

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

У меня вопрос по поводу интеграции alpakka_kafka+alpakka_s3.Alpakka s3 multipartUpload не загружает...

У меня есть поток типа Flow [T, Seq [Seq [String]], NotUsed]. Я бы хотел сгладить его так, чтобы...

Интересно, есть ли размер результирующего набора по умолчанию при выполнении DBAction с гладкой...

Документация Slick предупреждает, что для определенных баз данных размер выборки должен быть...

Когда я пытался запустить akka У меня была эта ошибка с ConfigFactory.load(): Exception in thread...