Я пытаюсь использовать akka-streams и akka-http и библиотеку alpakka для загрузки/выгрузки файлов на Amazon S3. Я вижу две проблемы, которые могут быть связаны... Я могу скачивать только очень маленькие файлы, самый большой 8kb. Я не могу...

Я читаю документацию по Alpakka Cassandra здесь Это позволяет очень легко использовать Cassandra в качестве источника и приемника. но как насчет использования потока. Под использованием потока я имею в виду, что я не использую Cassandra в...

В настоящее время я играю с Akka Streams и разъемом Alpakka MongoDB . . Можно ли указать тип для MongoSource ? val codecRegistry = fromRegistries(fromProviders(classOf[TodoMongo]), DEFAULT_CODEC_REGISTRY) private val todoCollection:...

Я написал код с Akka Streams и Alpakka, который считывает данные из Amazon SQS и индексирует события в Elasticsearch. Все работает гладко и производительность потрясающая, но у меня проблема с именами индексов. У меня есть этот код: class...

Я загружаю один файл на SFTP-сервер с помощью Alpakka, но после того, как файл загружен и я получил ответ об успешном завершении, приемник остается открытым, как его слить? Я начал с этого: val sink = Sftp.toPath(path, settings, false) val...

У меня есть Alpakka Elasticsearch Sink , который я храню между запросами. Когда я получаю запрос, я создаю Source из HTTP-запроса и превращаю его в Source Elasticsearch WriteMessage , а затем запускаю его с...

В другом месте StackOverflow ( ссылка ), доступ к AWS S3 осуществляется следующим образом: AmazonS3 amazonS3 = AmazonS3Client.builder() .withRegion("us-east-1") .withCredentials(new AWSStaticCredentialsProvider(creds)) .build(); Я...

Я пытаюсь загрузить большой файл (на данный момент 90 МБ) на S3, используя Akka HTTP с разъемом Alpakka S3. Он отлично работает с небольшими файлами (25 МБ), но когда я пытаюсь загрузить большой файл (90 МБ), я получаю следующую ошибку:...