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 If you perform an `INSERT...IF NOT EXISTS` then C* will return the status of the insert with clarifying details. This should be passed back to the user....
This can lead to starvation issues if other code in an applcation also connects to the same servers. Instead, it could use either: * allow configuration of connection settings to...
Do I understand it right that `CouchbaseSource.fromN1qlQuery()` doesn't support backpressure at all? I used `akka-stream-alpakka-couchbase:3.0.3` with Scala 2.12.13 and Akka 2.6.14 A graph like this being run on a dataset...
I'm planning to add MQTT v5 support to the mqtt-streaming subproject in the next weeks. I currently implemented most of the neccessary encoding/decoding in the file model.scala and updated the...
I use akka elasticsearch stream to bulk write to ES. When I upgrade from 2.0.2 to 3.0.4. I find a problem that elastic source read normally, but elastic bulk flow...
### Short description Currently there is a custom [script](https://github.com/akka/alpakka/blob/master/scripts/create-slow-minio.sh) that is used to setup a throttled Minio container for the ignored `S3SlowMinioIntegrationSpec`. A more ideal solution would be to use...
### Short description There is no way to set the compression level for Zip Archive ### Details When creating a zip file, we need a way to create an uncompressed...
### Short description AWS have a method of signing HTTP Requests [AWS Sigv4](https://docs.aws.amazon.com/general/latest/gr/sigv4_signing.html) which has now been taken up by the IETF and is being standardised by the HTTPBis WG...
The UDP bind flow does not have a buffer for incoming UDP packages and silently drops incoming if there is backpressure (see https://github.com/akka/alpakka/blob/master/udp/src/main/scala/akka/stream/alpakka/udp/impl/UdpBind.scala#L53 ) This probably not what you'd expect...
### Versions used Akka version: 2.6.14 Play version: 2.8.8 Alpakka version 3.0.3 ### Actual Behavior jackson module initialization failure : ``` [error] com.fasterxml.jackson.databind.JsonMappingException: Scala module 2.11.4 requires Jackson Databind version...
