Akka.net v1.5.0-alpha1

« Changelog History

Akka.net v1.5.0-alpha1 Release Notes

• ⬆️ Akka.NET v1.5.0-alpha1 is a major release that contains a lot of code improvement and rewrites/refactors. Major upgrades to Akka.Cluster.Sharding in particular.

  🗄 Deprecation

  📦 Some codes and packages are being deprecated in v1.5

  • 📦 Deprecated/removed Akka.DI package Please use the new Akka.DependencyInjection NuGet package as a replacement. Documentation can be read here
  • 📦 Deprecated/removed Akka.MultiNodeTestRunner package Please use the new Akka.MultiNode.TestAdapter NuGet package as a replacement. Documentation can be read here.
  • 🔨 [Streams] Refactor SetHandler(Inlet, Outlet, IanAndOutGraphStageLogic) to SetHandlers()

  🔄 Changes

  Akka

  • 👍 Add dual targetting to support .NET 6.0 All Akka.NET packages are now dual targetting netstandard2.0 and net6.0 platforms, we will be integrating .NET 6.0 better performing API and SDK in the future.
  • 👍 Add IThreadPoolWorkItem support to ThreadPoolDispatcher
  • 👍 Add ValueTask support to PipeTo extensions
  • 👍 Add CancellationToken support to Cancelable
  • Fix long starting loggers crashing ActorSystem startup All loggers are asynchronously started during ActorSystem startup. A warning will be logged if a logger does not respond within the prescribed akka.logger-startup-timeout period and will be awaited upon in a detached task until the ActorSystem is shut down. This have a side effect in that slow starting loggers might not be able to capture all log events emmited by the EventBus until it is ready.

  Akka.Cluster

  • ⏱ Fix ChannelTaskScheduler to work with Akka.Cluster, ported from 1.4
  • 👀 Harden Cluster.JoinAsync() and Cluster.JoinSeedNodesAsync() methods
  • 🔧 Fix ShardedDaemonProcess should use lease, if configured
  • Make SplitBrainResolver more tolerant to invalid node records
  • Enable Heartbeat and HearbeatRsp message serialization and deserialization By default, Akka.Cluster will now use the new Heartbeat and HartbeatRsp message serialization/deserialization that was introduced in version 1.4.19. If you're doing a rolling upgrade from a version older than 1.4.19, you will need to set akka.cluster.use-legacy-heartbeat-message to true.

  Akka.Cluster.Sharding

  • Make Cluster.Sharding recovery more tolerant against corrupted persistence data
  • Major reorganization to Akka.Cluster.Sharding

  ⬆️ The Akka.Cluster.Sharding changes in Akka.NET v1.5 are significant, but backwards compatible with v1.4 and upgrades should happen seamlessly.

  Akka.Cluster.Sharding's state-store-mode has been split into two parts:

  • CoordinatorStore
  • ShardStore

  🔧 Which can use different persistent mode configured via akka.cluster.sharding.state-store-mode & akka.cluster.sharding.remember-entities-store.

  Possible combinations:

  state-store-mode	remember-entities-store	CoordinatorStore mode	ShardStore mode
  0️⃣ persistence (default)	- (ignored)	persistence	persistence
  ddata	ddata	ddata	ddata
  ddata	eventsourced (new)	ddata	persistence

  🚚 There should be no breaking changes from user perspective. Only some internal messages/objects were moved. 🔧 There should be no change in the PersistentId behavior and default persistent configuration (akka.cluster.sharding.state-store-mode)

  🐎 This change is designed to speed up the performance of Akka.Cluster.Sharding coordinator recovery by moving remember-entities recovery into separate actors - this also solves major performance problems with the ddata recovery mode overall.

  The recommended settings for maximum ease-of-use for Akka.Cluster.Sharding going forward will be:

  akka.cluster.sharding{
    state-store-mode = ddata
    remember-entities-store = eventsourced
  }
  

  0️⃣ However, for the sake of backwards compatibility the Akka.Cluster.Sharding defaults have been left as-is:

  akka.cluster.sharding{
    state-store-mode = persistence
    # remember-entities-store (not set - also uses legacy Akka.Persistence)
  }
  

  Switching over to using remember-entities-store = eventsourced will cause an initial migration of data from the ShardCoordinator's journal into separate event journals going forward - this migration is irreversible without taking the cluster offline and deleting all Akka.Cluster.Sharding-related data from Akka.Persistence, so plan accordingly.

  Akka.Cluster.Tools

  • 👍 Add typed ClusterSingleton support
  • 📇 Singleton can use Member.AppVersion metadata to decide its host node during hand-over Akka.Cluster.Singleton can use Member.AppVersion metadata when it is relocating the singleton instance. When turned on, new singleton instance will be created on the oldest node in the cluster with the highest AppVersion number. You can opt-in to this behavior by setting akka.cluster.singleton.consider-app-version to true.

  Akka.Persistence.Query

  • Add TimeBasedUuid offset property

  Akka.Remote

  • Fix typo in HOCON SSL settings. Backward compatible with the old setting names
  • Treat all exceptions thrown inside EndpointReader message dispatch as transient, Ported from 1.4
  • Fix SSL enable HOCON setting

  Akka.Streams

  • Allow GroupBy sub-flow to re-create closed sub-streams, backported to 1.4
  • Fix ActorRef source not completing properly, backported to 1.4
  • Rewrite ActorRefSink as a GraphStage
  • Add stream cancellation cause upstream propagation, ported from 1.4
  • Fix VirtualProcessor subscription bug, ported from 1.4
  • 🔨 Refactor Sink.Ignore signature from Task to Task<Done>
  • Add SourceWithContext.FromTuples() operator`
  • Add GroupedWeightedWithin operator
  • Add IAsyncEnumerable source

  ✅ Akka.TestKit

  • ✅ Rewrite Akka.TestKit to work asynchronously from the ground up

• All Versions
• Previous v1.4.37
• Next v1.5.0-alpha2
• Latest Version