Release Notes (1.2.x)

Apache Pekko 1.2.x releases support Java 8 and above.

1.2.1

Pekko 1.2.1 has some bug fixes and some code has been deprecated to signal that it is likely to be removed in 2.0.0. See the GitHub Milestone for 1.2.1 for a fuller list of changes.

Bug Fixes

  • Add back BackoffSupervisor.calculateDelay due to bin compat issues (PR2195)

Changes

  • Add OSGi headers to pekko-pki (PR2109)

Dependency Changes

  • netty 4.2.5.Final
  • lightbend/config 1.4.5

1.2.0

Pekko 1.2.0 has some new features, performance updates and dependency upgrades. See GitHub Milestone for 1.2.0-M1, GitHub Milestone for 1.2.0-M2 and GitHub Milestone for 1.2.0 for a fuller list of changes.

Most of the changes appeared in the milestone releases (1.2.0-M1 and 1.2.0-M2) but some additional changes were made for the 1.2.0 release. These extra changes include deprecating some methods that will be removed in a future release.

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)
  • 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 to 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)
  • Allow overriding dispatcher in mapWithResource (PR1949)
  • Fix issue with ByteBuffer cleaner only working with Java 8 (PR2020)

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 (PR1468)
  • Add Identity function to Java DSL (PR1671)
  • Add support for controlling the NettyTransport’s byteBuf allocator type (PR1707)
  • 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)
  • Add JournalPersistFailed and JournalPersistRejected signals (PR1961)
  • Make calculateDelay a public method (PR1940)
  • Allow disabling AsyncWriteJournal.Resequencer to improve latency (#2026)
  • Add CompletionStages helper (PR2060)

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)
  • 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.32.0 (PR1795, PR2036)
  • 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 Algorithm class (pekko-serialization-jackson) (PR1932)
  • Deprecate FunctionalInterfaces that are being removed in pekko 2.0.0 (PR2004, PR2075)
  • Disable batch if isVirtualized (PR2046)
  • Deprecate more methods in Futures (PR2048)
  • Remove incorrect deprecation in IOResult (PR2054)
  • Make timeoutCompletionStage accept Java Duration (PR2063)

Dependency Changes

  • netty 4.2.4.Final
  • jackson 2.19.2
  • lightbend/config 1.4.4
  • protobuf-java 4.32.0
  • slf4j 2.0.17
  • junit-jupiter 5.13.4
  • scala 2.12.20, 2.13.16, 3.3.6

Known Issues

This release breaks binary compatibility for pekko-persistence-cassandra and users of that lib will need to avoid Pekko 1.2.0 release. We fixed this in the 1.2.1 release.

1.7.1