alpakka
alpakka copied to clipboard
akka
Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
I am writing a web server where I need to list the contents of directories efficiently, so that I can return creation date, time created, etc... to the client. The...
### Versions used alpakka-s3 2.0.2 alpakka-csv 2.0.2 Akka version: 2.5.31 ### Expected Behavior Using Sink.runWith(S3.multipartUpload("exports.aturner.practicumfit.com", "my-file.csv")) should yield a successful output. ### Actual Behavior the bucket fails with the error...
There's no integration testing currently done in the google-cloud-stroage connector. This issue was raised in https://github.com/akka/alpakka/issues/2163 . Some posts about using the `google/cloud-sdk` Docker image in a test suite: https://medium.com/@mrkrijgsman/integration-testing-pub-sub-interactions-in-your-application-45e35476de23...
``` --> [akka.stream.alpakka.ftp.StrictHostCheckingSftpSourceSpec: FtpIOSource should retrieve a bigger file (~2 MB) from path and offset as a stream of bytes] Start of log messages of test that [Failed(java.lang.AssertionError: assertion failed:...
``` [error] org.parboiled.errors.ParserRuntimeException: Error while parsing action 'Root/Sequence/ZeroOrMore/Sequence/Block/FirstOf/Sequence/FirstOf/Table/Sequence/Optional/Sequence/NodeSequence/Sequence/TableRow/Sequence/OneOrMore/Sequence/TableCell/NodeSequence/Sequence/OneOrMore/Sequence/Inline/Inline_Action1' at input position (line 4, pos 47): [error] This library combines the convenience of Akka Streams with KCL checkpoint management, failover, load-balancing,...
I am using MQTT streaming flow through server session but I have clients outside of Akka to communicate with that server with credentials for security reasons. Is that supported? If...
``` [error] Test docs.javadsl.CassandraSourceTest.createSession failed: java.util.concurrent.TimeoutException: null, took 10.01 sec [error] at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) [error] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) [error] at scala.concurrent.java8.FuturesConvertersImpl$CF.super$get(FutureConvertersImpl.scala:84) [error] at scala.concurrent.java8.FuturesConvertersImpl$CF.$anonfun$get$2(FutureConvertersImpl.scala:84) [error] at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:57) [error] at scala.concurrent.package$.blocking(package.scala:146) [error] at...
### Short description It's about a possibility to create a file path for each new file depending on timestamp supplied in hdfs messages. ### Details Currently the only possibility is...
### Versions used val AkkaStreamAlpakka = "2.0.2" val AmazonKinesisClient = "2.3.3" val AWSSDK = "2.15.82" ### Expected Behavior After starting localstack kinesis, I ran a source to a `Sink.head`, then...
We are forming Insert query in Slick.flowWithPassThrough() by providing slick session and ActorSystem dispatcher. The returned flow from Slick.flowWithPassThrough() is wrapped by RetryFlow.withBackoff() for any connection related retry. The query...
