pjfanning opened a new pull request, #3277: URL: https://github.com/apache/pekko/pull/3277
Copy over some Akka 2.8.3 changes that are now available under Apache License, version 2.0. https://github.com/akka/akka-core/releases/tag/v2.8.3 This takes the persistence-query changes from #3270 as part of splitting that PR in 2. ### EventsBySliceFirehoseQuery (PR 31957 + 31980 + 31981) - New `EventsBySliceStartingFromSnapshotsQuery` trait (scaladsl + javadsl) - New `EventsBySliceFirehose` internal extension (~826 lines): shares a single DB-query stream via `BroadcastHub`, fans out to multiple consumers, detects and aborts slow consumers - New `EventsBySliceFirehoseQuery` (scaladsl + javadsl): wraps a delegate `EventsBySliceQuery` plugin and exposes it under `pekko.persistence.query.events-by-slice-firehose` - `EventsBySliceFirehoseReadJournalProvider` wires scaladsl/javadsl instances - Config block added to `persistence-query/src/main/resources/reference.conf` - `TestClock` test helper and `EventsBySliceFirehoseSpec` with PR 31981 hardening (deterministic consumer-progress and slow-consumer-abort tests) - https://github.com/akka/akka-core/pull/31957, https://github.com/akka/akka-core/pull/31980, https://github.com/akka/akka-core/pull/31981 ### Translation notes - All `akka.*` package/config references → `org.apache.pekko.*` / `pekko.*` - `scala.compat.java8.FutureConverters` → `scala.jdk.FutureConverters` (`.toJava`/`.asJava`) - `akka.util.JavaDurationConverters` → `scala.jdk.DurationConverters` (`.toScala`) - `akka.util.ccompat.JavaConverters` → `scala.jdk.CollectionConverters` - `@unused` (`akka.util.unused`) → `@nowarn("msg=never used")` (`scala.annotation`) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
