alpakka
alpakka copied to clipboard
akka
Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
### Short description Allow known_hosts file to be loaded from resources or memory. ### Details Alpakka only allows loading the known_hosts file from file system. This prevents applications to package...
The OrientDb client library has been rewritten and the Alpakka usage is now mostly deprecated. I disabled fatalWarnings for OrientDb in #2628 so it can be addressed later.
References #2577 Adding by the PR a FilePathGenerator option of creating a new path for each file depending on rotation count and timestamp supplied by hdfs messages. An assumption is...
https://travis-ci.com/github/akka/alpakka/jobs/380666695 ``` [info] - should produce a duplicate publish on the server given two client connections *** FAILED *** (5 seconds, 535 milliseconds) [info] java.lang.AssertionError: assertion failed: expected no StreamSupervisor...
### Versions used Akka version: Alpakka-file - 2.0.2 and current snapshot version ### Expected Behavior When streaming tar file via `Compression.gunzip()` and `Archive.tarReader()` and in the final stage using either...
By any chance, Is it possible to access the PositionedResult through SlickRow? More specifically, I want to access JDBC's ResultSet from SlickRow through PositionedResult. https://github.com/akka/alpakka/blob/925786a05cd80515a10992007dbab0506c014f9e/slick/src/main/scala/akka/stream/alpakka/slick/javadsl/package.scala#L60
https://travis-ci.com/github/akka/alpakka/jobs/505340145#L1511 ``` [info] - should enable throttling on emptyReceives and disable throttling when a new message arrives *** FAILED *** (9 seconds, 19 milliseconds) [info] java.lang.AssertionError: Expected OnNext(_), yet no...
### Short description There is no API for removing a remote FTP/SFTP directory. ### Details As far as I can tell, removal of remote FTP/SFTP directories is not supported -...
Right now the Elasticsearch connector only supports creating a `Source` based on a scrolling search. Would it be a good fit to add support for a `Source` based on the...
### Short description Let the user control what failures to retry when writing to ElasticSearch. ### Details The ElasticSearch retry functionality does not allow the user to distinguish between transient...