В настоящее время я использую Akka-Camel для интеграции своего приложения на основе Akka с различными очередями сообщений. Теперь, когда я хочу перейти на последнюю версию Akka, я вижу, что эта интеграция устарела. Я пытался использовать...

Я работаю над реализацией Akka Alpakka для потребления и создания очередей ActiveMQ на Java. Я могу успешно получать из очереди, но я еще не смог реализовать подтверждение сообщения на уровне приложения. Моя цель — получать сообщения из очереди и...

Я пытаюсь настроить Alpakka S3 для загрузки файлов. Вот мои конфиги: Альпакка s3 зависимость: ... "com.lightbend.akka" %% "akka-stream-alpakka-s3" % "0.20" ... Вот application.conf : akka.stream.alpakka.s3 { buffer = "memory"...

Alpakka предоставляет отличный способ доступа к десяткам различных источников данных. Файловые источники, такие как HDFS и FTP, поставляются как Source[ByteString, Future[IOResult] . Однако HTTP-запросы через Akka HTTP доставляются как потоки...

Думая о переносе некоторого наследия на основе JMS на Alpakka, одним из широко используемых шаблонов в коде является запрос/ответ с временной очередью (JMSReplyTo). Возможно ли это с Alpakka из коробки?

Я пытаюсь создать код, который использует ключи S3, затем загружает эти файлы с S3, затем сохраняет эти данные в файл на диске с именем ключа (необходимым для дальнейшего процесса) и в качестве вывода возвращает ключ/имя файла. Что у меня есть до сих...

У меня есть простой коммитируемый источник для потока Kafka, завернутый в RestartSource. Он отлично работает в счастливом пути, но если я намеренно разорву соединение с кластером Kafka, он выдаст исключение соединения из базового клиента kafka и...

Я использую Akka Streams, а также alpakka.sqs.scaladsl для чтения сообщений из очереди sqs. Я делал это много раз, но теперь я загрузил версию, в которой имя очереди помещалось в источник вместо URL-адреса очереди, как я делал это все время. вот...

Я пытаюсь использовать разъем Amqp alpakka в качестве источника и приемника. Source<CommittableReadResult, NotUsed> AMQP_SOURCE -> processAndGetResponse -> Sink<ByteString, CompletionStage<Done>> AMQP_SINK...

У меня есть простой кусок кода, основанный на примерах alpakka, который должен загрузить какой-то файл с S3 для дальнейшей обработки: S3.download(bucket, file) .runWith(Sink.head) .flatMap { case Some((data, _)) =>...

Я вижу следующую трассировку стека с mongo-driver-reactivestreams: 4.1.1 2021-01-14 17:33:39.662 | ERRORSECURITY | | 11726 ms| akka.actor.ActorSystemImpl | Uncaught error from thread...