Release Notes (1.2.x)
Apache Pekko 1.2.x releases support Java 8 and above.
1.2.0-M2
Pekko 1.2.0-M2 has some new features, performance updates and dependency upgrades. See the GitHub Milestone for a fuller list of changes.
This is milestone release and is aimed at testing some new changes. This release should ideally not be used in production.
Bug Fixes
- Issue forming mixed Akka/Pekko cluster when classic remoting with SSL/TLS is used (PR1857)
- Join cluster check adjusted to support Akka nodes (PR1866, PR1877)
- If you are attempting to mix Akka and Pekko nodes in a cluster, it is still recommended to disable the join cluster check but these changes may be enough to get it work (docs).
- BroadcastHub drops elements due to register/unregister race (PR1841)
- Fix issue with number deserialization in pekko-cluster-metrics (PR1899)
- Fix typed persistence stack overflow with many read only commands (PR1919)
Additions
- Add Pattern timeout support (PR1424)
- Add TraversalBuilder.getValuePresentedSource method for further optimization (PR1701)
- Add flatmapConcat with parallelism support (PR1702)
- add EventsByTagQuery to JavaDSL PersistenceTestKitReadJournal (PR1763)
- Implement EventsBySliceQuery in JavaDSL PersistenceTestKitReadJournal (PR1767)
- Persistence API: add CurrentLastSequenceNumberByPersistenceIdQuery (PR1773)
- Add emitMulti with Spliterator support (PR1776)
- Add switchMap stream operator (PR1787)
- Add invokeWithFeedbackCompletionStage for javadsl (PR1819)
- Add takeUntil stream operator (PR1820)
- Add Source#create method (PR1823)
- Support Jackson Enum Features (PR1845)
- Add dropRepeated stream operator (PR1868)
- Add onComplete support for statefulMapConcat operator (PR1870)
- Add groupedAdjacentBy and GroupedAdjacentByWeighted stream operators (PR1937)
- Make calculateDelay a public method (PR1940)
Changes
- Tweak withAttributes in Flow (PR1658)
- Handle NormalShutdownReason in MergeHub (PR1741)
- optimize recoverWith to avoid some materialization (PR1775)
- Regenerated all the source code for Protobuf using 4.29.3 (PR1795)
- Avoid materialize an empty source in switchMap (PR1804)
- Fix wrong name attribute for iterate and mapAsyncPartitionUnordered operators (PR1869)
- Change aggregateWithBoundary operator in javadsl to use Optional (PR1876)
- TLS v1.3 is now the default (PR1901)
- Set vector builder to null after stage completed to avoid leak (PR1917)
- Renamed internal Alogithm class (pekko-serialization-jackson) (PR1932)
Dependency Changes
- netty 4.2.2.Final
- jackson 2.19.1
- lightbend/config 1.4.4
- protobuf-java 4.31.1
- slfj4 2.0.17
- jupiter-junit 5.13.3
1.2.0-M1
Pekko 1.2.0-M1 has some new features, performance updates and dependency upgrades. See the GitHub Milestone for a fuller list of changes.
This is milestone release and is aimed at testing some new changes. It is expected that there will be at least one more milestone before a full release. This release should ideally not be used in production.
Bug Fixes
- Fix a leak in FlatMapPrefix operator (PR1622)
- Fix a leak in PrefixAndTail operator (PR1623)
- Fix occasional ordering issue in FlowWithContext#unsafeOptionalDataVia (PR1681)
- Add the missing EmptySource case to TraversalBuilder (PR1743)
Additions
- add non-default config that allows InboundQuarantineCheck to ignore ‘harmless’ quarantine events (PR1555)
- New Sink.none operator (PR1614)
- Add overridden duration timeout to StreamTestKit (PR1648)
- Add Identity function to Java DSL (PR1671)
- Add support for controlling the NettyTransport’s byteBuf allocator type (PR1707)
Changes
- Make flatMapPrefix javadsl using java.util.List (PR271)
- Add SchedulerTask which will be notified once cancelled (PR1593)
- Reduce loops when cleaning queue in BroadcastHub (PR1628)
- Avoid calling finalizeStage more times than once (PR1650)
- avoid boxing in zipWithIndex and fix type signature in SubSource#zipWithIndex (PR1669)
- Avoid forwarding method on ArrayDequeue in stream module (PR1687)
- Avoid forwarding method on ArrayDequeue in BatchingExecutor (PR1688)
- Enhance virtual thread support (PR1724)
- Add LoadMetrics support for virtual thread executor (PR1734)
Dependency Changes
1.2.0-M2