Я пытаюсь использовать библиотеку akka-kryo-serializer. Мне удается заставить его работать со...

Я использую Alpakkas UDP.bindFlow для пересылки входящих UDP-дейтаграмм в брокер Kafka. Устаревшее...

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

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

У меня есть graphdsl, где по какой-то причине после выполнения webSocketClientFlow Flow я получаю...

Какой правильный преобразователь нужно добавить для раскрытия akka-streams и akka-http-streams? Я...

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

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

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

Я пытаюсь реализовать поток входа в Websocket с помощью Akka Flow. Я получаю множество неприятных...

Недавно я начал использовать Akka и использую его для создания REST API, используя Akka HTTP для...

Я использую Kakfa-клиент с потоком Akka, и даже в моем материализаторе определена стратегия...

мы используем последний S3-разъем alpakka для загрузки потока, но он не работает с ошибкой...

У меня есть: val fileStream: Source[ByteString, Any] = Source.single(ByteString

В своем проекте я использую akka-http и responsetivemongo и сортирую / отменяю классы дел с помощью...

По определению ответ http делится на 3 части , status-code -> headers -> body, а при...

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

Допустим, у нас есть два разных упорядоченных источника akka-stream: val source1: Source[Int,...

Мы используем версию ODL Nitrogen. Когда мы выполняем теплый запуск (т. Е. Перезапускаем серверы...

Я разрабатываю клиент-серверное приложение, используя Akka Http и Akka Streams. Основная идея...

У меня есть поток, которым нужно управлять через http api (запуск, остановка, только один...

Мне нужно реализовать процесс, который опрашивает сообщения из очереди и перенаправляет данные в...

У меня есть график, который обрабатывает большой файл. Доступ к файлу осуществляется через итератор...

Я пытаюсь реализовать пакетную обработку. Мой алгоритм: 1) Сначала мне нужно запросить элементы из...

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