Johan Andrén

Failed: ReplicatorPruningSpec

15

https://jenkins.akka.io:8498/job/akka-artery-cluster-tests/2231/consoleText ``` 10 was not equal to 11 (ReplicatorPruningSpec.scala:229) ```

In https://github.com/akka/akka/issues/27125 we saw that SingleConsumerOnlyUnboundedMailbox was slightly faster than the default classic mailbox and set it as default for typed actors, since no balanced pool API is available there....

Warnings in multinode tests - gcp auth plugin deprecated

2

``` 2022-05-16T04:07:53.4971796Z To learn more, consult https://cloud.google.com/blog/products/containers-kubernetes/kubectl-auth-changes-in-gke 2022-05-16T04:07:53.6939472Z [error] W0516 04:07:53.693601 104660 gcp.go:120] WARNING: the gcp auth plugin is deprecated in v1.22+, unavailable in v1.25+; use gcloud instead. ```

Possible problems with typed adapters

5

Noticed by @leviramsey : Message adapters are kept in a list which is prepended to after filtering out any created adapter for the exact same incoming message type. When applying...

Failed: SurviveNetworkInstability

5

https://jenkins.akka.io:8498/job/akka-artery-cluster-tests/2376/consoleText ``` must heal after unreachable when ring is changed (on node 'seventh', class akka.cluster.SurviveNetworkInstabilityMultiJvmNode7) *** FAILED *** (59 seconds, 962 milliseconds) [info] [JVM-7]  Set(akka://[email protected]:54699, akka://[email protected]:49828, akka://[email protected]:37807, akka://[email protected]:40144, akka://[email protected]:55101)...

Possibility to opt out of message ordering guarantee in sharding

7

When a shard is being rebalanced between nodes, a shard region tries as best as possible to buffer the messages and then forward to the new final destination, however, there...

Akka Persistence Cassandra plugin up to 0.104 (because of the underlying Cassandra client) requires explicit programmatic set of consistency levels on each `PreparedStatement`. The read side offset tracking in https://github.com/lagom/lagom/blob/master/persistence-cassandra/core/src/main/scala/com/lightbend/lagom/internal/persistence/cassandra/CassandraOffsetStore.scala...

UDP bind flow silently drops on backpressure

2

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...

https://travis-ci.com/github/akka/akka-persistence-cassandra/jobs/506130044 ``` [info] - must recover if snapshot is for the latest sequence nr *** FAILED *** (20 seconds, 715 milliseconds) 3640[info] java.lang.AssertionError: assertion failed: timeout (20 seconds) during expectMsg:...

Revisit DNS resolution for Akka HTTP client backend

1

I may have missed something but it looks as though the client now uses the regular blocking JDK infrastructure to resolve the hardcoded/grpc-dns hostname? https://github.com/akka/akka-grpc/blob/92bcd0344ef6c638b4142a7b11609b1579f44fbf/runtime/src/main/scala/akka/grpc/internal/AkkaHttpClientUtils.scala#L72