alpakka

alpakka copied to clipboard

Failed: OrientDBFlow should kafka-example - store documents and pass Responses with passThrough

2

``` [info] OrientDBFlow title: Book 1 title: Book 2 title: Book 3 [info] - should kafka-example - store documents and pass Responses with passThrough *** FAILED *** (106 milliseconds) [info]...

2m

Update AvroParquet to latest version

1

### Short description Upgrade the dependency for AvroParquet to latest version. ### Details Current version used in AvroParquet writer is 1.10.0. That is almost three years old and the latest...

dlmutart

AWS is working on changing the formats of their S3 paths. In [this article](https://aws.amazon.com/blogs/aws/amazon-s3-path-deprecation-plan-the-rest-of-the-story/) it is explained that support for `path-style` was to be deprecated in September 2020. However, this...

agboom

KuduFlowStage doesnt support UNIXTIME_MICROS type

1

Hi, I have a table in impala and one of the column type is "TIMESTAMP". And when i read this table via kudu table, the schema shows it as a...

stephenrooban

S3: Expose ClientConnectionSettings.idleTimeout in S3Settings

2

### Short description Downloading a huge file to a slow consumer might cause a `java.io.IOException: akka.stream.scaladsl.TcpIdleTimeoutException: TCP idle-timeout encountered on connection to [minio:80], no bytes passed in the last 1...

an-tex

[XML] XML parsing exceptions (e.g. WFCException) should cleanly fail the XmlParsing stage rather than go unhandled

1

In the XmlParsing stage, if any parsing error occurs, the exception from the underlying aalto parser goes unhandled and fails the stage. As a result, the exception is always logged...

jphelp32

Failed: MqttFlowSpec mqtt server flow should receive a bidirectional connection and a subscription to a topic

23

``` [info] MqttFlowSpec: [info] mqtt client flow [info] - should establish a bidirectional connection and subscribe to a topic (488 milliseconds) [info] mqtt server flow [info] - should receive a...

2m

https://travis-ci.com/github/akka/alpakka/jobs/335742573 ``` 08:57:02.742 INFO [pool-1-thread-1 ] a.s.a.t.javadsl.LogCapturingJunit4 Logging started for test [akka.stream.alpakka.ftp.SftpWithProxyStageTest: fromPath] 08:57:02.757 DEBUG [default-dispatcher-6] akka.actor.ActorSystemImpl Dispatcher id [akka.stream.materializer.blocking-io-dispatcher] is an alias, actual dispatcher will be [akka.actor.default-blocking-io-dispatcher] 08:57:02.783 DEBUG...

raboof

In #2433 ``` [info] MqttSessionSpec: [info] MQTT server connector [info] - should unsubscribe a server session *** FAILED *** (3 seconds, 170 milliseconds) java.lang.AssertionError: assertion failed: timeout (3 seconds) during...

ennru

PubSub GRPC does not handle server disconnection/retryable error

2

### Versions used Alpakka version: 1.0-RC1 Akka version: 2.5.21 ### Expected Behavior Subscribing with a PubSub GRPC client to a topic subscription using a streaming pull request should yield a...

vladimir-lu