У меня есть источник source типа Source[ByteString, Any] и приемник sink типа Sink[ByteString, M],...

Я пытаюсь прочитать файл avro с Source из akka Streams. Источник в потоках akka читает данные,...

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

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

Итак, у меня есть следующий тип: case class Episode( parentTconst: String, seasonNumber: Int,...

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

У меня есть клиент websocket, который выглядит следующим образом: object Main extends App { private...

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

Я создал очень простой поток akka на основе проекта alpakka, но он ничего не читает из kafka, даже...

У меня есть одна из наших систем Python, генерирующая файлы Parquet с использованием Pandas и...

Я пытаюсь проверить, является ли тема, переданная моему методу "start stream", допустимой / уже...

Я использую Akka WebSockets для связи клиент-сервер. На клиенте: source .viaMat(Http()

Имеет два входных потока, каждый из которых создает экземпляры объектов, определенные как case...

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

У меня есть две службы: одна отправляет потоковые данные, а вторая получает их, используя akka-grpc...

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

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

Я столкнулся с проблемой использования XmlDecoder в AkkaStream только в приложении, работающем в...

У меня есть Spring WebFlux контроллер: @RestController public class Controller {...

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

Совершенно новый для потоков Akka, и я наткнулся на этот кусок кода на днях, находясь на работе.Я...

ElasticSearch версия: 5.1.1 Мне нужно получить один индекс, содержащий миллионы документов. По сути...

Ниже приведен упрощенный фрагмент кода, где реализация GraphStateLogic передается в GraphStage в...

Как уже говорилось, у меня есть несколько Source.queue и FileIO в качестве приемника.В документации...

Я ищу оператора Akka Streams, который позволил бы мне разделить поток на основе пользовательской...