Release Notes (1.2.x)

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

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

  • jackson 2.18.2 - it is recommended for users to uptake jackson 2.18.3 when it is released due to some bug fixes (PR1556)
  • netty 4.1.117.Final
  • protobuf-java to 3.25.6 (PR1748)
  • scala 2.12.20, 2.13.16, 3.3.5
1.2.0-M1+34-3aacafe4*