Johan Andrén
Johan Andrén
Use case popped up in the Alpakka S3 connector (https://github.com/akka/alpakka/pull/2982#discussion_r1214175798) , but I _think_ this cold be a general use case: we want to turn stream elements into requests against...
https://github.com/akka/akka/actions/runs/5439934520/jobs/9892367118#step:10:8614 ``` [info] [JVM-1] - must pool local: on, role: b, 6 => 0,2,2 (on node 'first', class akka.cluster.routing.UseRoleIgnoredMultiJvmNode1) *** FAILED *** (10 seconds, 105 milliseconds) [info] [JVM-1] 9 did...
Spawned by this question: https://discuss.lightbend.com/t/create-source-from-sink-and-vice-versa/605 Maybe we should have a prepackaged thing for this?
Includes caching in the same action
https://github.com/akka/alpakka/actions/runs/4720327828/jobs/8372240424?pr=2964#step:6:58 ``` [error] Test docs.javadsl.CassandraFlowTest failed: java.lang.RuntimeException: timeout 10s hit, took 0.0 sec [error] at docs.javadsl.CassandraTestHelper.await(CassandraTestHelper.java:64) [error] at docs.javadsl.CassandraTestHelper.(CassandraTestHelper.java:38) [error] at docs.javadsl.CassandraFlowTest.beforeAll(CassandraFlowTest.java:50) [error] ... [error] Caused by: java.util.concurrent.TimeoutException: Future timed...
akka.stream.alpakka.google.auth.Credentials.parseComputeEngine blocks the calling thread on a HTTP call to a gcloud endpoint
https://github.com/akka/alpakka-kafka/actions/runs/4698741175/jobs/8331468745#step:6:190 ``` [info] - should map messages one-to-many, and commit in batches *** FAILED *** (10 seconds, 279 milliseconds) [info] Vector(ConsumerRecord(topic = topic-2-85, partition = 0, leaderEpoch = 0, offset...
Even though the `IntegrationTest` config now is deprecated https://www.scala-sbt.org/1.x/docs/Testing.html#Integration+Tests shows it as the way to do integration tests. Probably at least drop that section. Even better would be to replace...
New per-service client config with an interval to trigger (possibly) cache-piercing refresh of discovered endpoints for a service. Depends on upstream API addition in Akka. References #1152