Build highly concurrent, distributed, and resilient message-driven applications on the JVM

Last update: Jan 3, 2023

Overview

Akka

We believe that writing correct concurrent & distributed, resilient and elastic applications is too hard. Most of the time it's because we are using the wrong tools and the wrong level of abstraction.

Akka is here to change that.

Using the Actor Model we raise the abstraction level and provide a better platform to build correct concurrent and scalable applications. This model is a perfect match for the principles laid out in the Reactive Manifesto.

For resilience, we adopt the "Let it crash" model which the telecom industry has used with great success to build applications that self-heal and systems that never stop.

Actors also provide the abstraction for transparent distribution and the basis for truly scalable and fault-tolerant applications.

Learn more at akka.io.

Reference Documentation

The reference documentation is available at doc.akka.io, for Scala and Java.

Community

You can join these groups and chats to discuss and ask Akka related questions:

Forums: discuss.akka.io
Chat room about using Akka:
Issue tracker:

In addition to that, you may enjoy following:

The news section of the page, which is updated whenever a new version is released
The Akka Team Blog
@akkateam on Twitter
Questions tagged #akka on StackOverflow
Projects built with Akka:

Contributing

Contributions are very welcome!

If you see an issue that you'd like to see fixed, the best way to make it happen is to help out by submitting a pull request implementing it.

Refer to the CONTRIBUTING.md file for more details about the workflow, and general hints on how to prepare your pull request. You can also ask for clarifications or guidance in GitHub issues directly, or in the akka/dev chat if a more real time communication would be of benefit.

A chat room is available for all questions related to developing and contributing to Akka:

License

Akka is Open Source and available under the Apache 2 License.

Comments

+str #15977 add SourceFlow/SinkFlow
sources must really be sources (the same for sinks), hence ProcessorFlow cannot implement either of these

therefore they are just other names for FlowWithSource/Sink

also fixed type-safety of FlowGraph’s edge labels

tested
opened by rkuhn 81
Cluster node can't join after restart

As described here https://groups.google.com/forum/#!topic/akka-user/AdRSv2yuwo4 a quickly restarted node starts responding to heartbeats and becomes reachable according to the cluster even though it is a new node and is not allowed to join.
bug t:remoting

opened by bantonsson 76
Introduces `fold` as a Flow transformation and generalizes Sink.fold …

I think there's quite a few use cases for running a fold and then building on top of the result of that, perhaps splitting or "decompressing" the folded result value into new flow elements downstream.

This PR also includes a few other improvements.
tested t:stream

opened by viktorklang 73
Add java.time.Duration to Java APIs

After many many discussions:

We discussed this and are willing to give it to try to add java duration.

This is the super ticket, which should list all places where we want to add it, and then small PRs to address each of those.
help wanted good first issue

opened by ktoso 65
Let the application specify custom MDC values

Hi guys,

With some modifications to LoggingAdapter, BusLogging and Slf4jLogger I was able to let the application specify custom MDC values when logging any message. This new feature is hard to use as it is, but combined together with an Akka pattern I'm developing ( https://github.com/ktonga/akka-contextual-actors ) the experience of being using a transparent MDC solution gets a little bit more real.

Let me know if you need some further modifications! Thanks.
reviewed tested

opened by ktonga 65
Replace LazyFlow with FutureFlow (and implement other lazy flows on top of it)
take a stub at #28016

implement futureFlow as a building block.

implement lazyFutureFlow and friends in terms of futureFlow and flatMapPrefix

fix few failing tests that seem tp have violate the docs

this is still WIP, I think it especially requires a comprehensive test suite for the newly introduce FutureFlow graph stage.
tested t:stream
opened by eyalfa 64
Reliable delivery in Typed, #20984
Approach

I'm taking a rather different approach than in classic AtLeastOnceDelivery because I would like:

support plain flow control, with a work pulling approach

be possible to use with or without persistence (without it may loose messages if producer node crashes)

detect lost messages on the consumer side and let that drive resends, instead of aggressively resending from producer side

deliver messages in order and deduplicate resent messages

have an efficient protocol for acknowledgments over the network (not ack each message), but still have a simple one-by-one protocol for the end user

I have thought of 3 separate usage cases:

Point-to-point between one producer and one consumer, this is also the building block of other usages.

Work pulling pattern, where workers register to one work producer master. Workers are equal and a message can be routed to any of the workers that has demand.

Sharding. Routing to the destination is based on the entityId. Many producers can send to the same destination entity.

Those use cases are illustrated in the tests in ReliableDeliverySpec, WorkPullingSpec, ReliableDeliveryShardingSpec.

Point-to-point

ProducerController and ConsumerController are point-to-point with single producer and single consumer.

The ScalaDoc in ProducerController and ConsumerController describes how it works and the message protocol.

Work Pulling

ConsumerController (CC-1) is started for worker-1, and registered to the Receptionist.

The WorkPullingProducerController receives the Listing from the Receptionist and spawns a ProducerController (PC-1) for CC-1. The PC-1/CC-1 pair is used for delivery of messages selected for worker-1.

Another worker-2 is started and registered. Corresponding ProducerController (PC-2) for CC-2. The PC-1/CC-1 pair is used for delivery of messages selected for worker-1.

The WorkPullingProducerController randomly selects worker for each message (job) among the workers with demand (according to the PC/CC pair request window).

Sharding

A ShardingProducerController is started for each producer, typically one per node. Messages to any entity can be sent via this ShardingProducerController. For the first message for an entity it spawns a ProducerController (PC-entity-1), which is used for delivery of messages to that specific entity.

Sharding creates the ShardingConsumerController for the first message to that entity, which spawns the application's entity Behavior.

A ConsumerController (CC-a) is also spawned and is working in pair with the ProducerController (PC-entity-1).

Message for another entity means that the ShardingProducerController will spawn another ProducerController (PC-2) for that entity.

There can be many producers, typically one per node. The ShardingConsumerController will spawn a new ConsumerController for each producer.

TODO:

[x] actual public api

[x] more around the work pulling support

[x] more around the sharding support

[x] real impl of the DurableProducerQueue

[x] configuration

[x] logging

[x] protobuf serialization

[x] api and reference documentation

[x] other fixmes

Refs #20984
tested
opened by patriknw 60
Added changes to Netty pipelines to support SSL/TLS. Fixes #1978
Netty server and client pipelines updated to conditionally load keystore/truststore if SSL is enabled in the config

Supports any available encryption protocol via 'ssl.protocol'

Supported encryption algorithms are specified via 'ssl.encryption-protocol' config key
opened by dev10 60
SourceWithContext and FlowWithContext
Based on earlier work by Johannes

[x] More docs

[x] Java version

I have added ApiMayChange @patriknw @jrudolph and processed @2m comments. Let me know if anything more is required for now.
tested
opened by RayRoestenburg 59
=str #19299 Performance Flow.flatMapMerge

Ref: #19299 This PR creates short circuit for Async Requests that are made within the same ActorGraphInterpreter (has the same actor) by different logics. Main use case is when substream exchanges events with main stream and vice-versa
tested

opened by agolubev 59
Http: HttpEntity stream cancellation

Here's an attempt to solve issues #18010 and #18203.

First commit can be treated as a simpler version of the solution, which involves adding eagerClose flag to splitWhen in order to define how substream cancelation should be treated: by draining the remaining elements in order to prevent stalling (current behaviour) or cancelling the stage altogether.

Second one introduces custom stage instead of splitWhen/prefixAndTail pipeline, which would allow to add eagerClose flag to outgoingConnection without adding flag to splitWhen/splitAt if this change isn't plausible.

I used https://github.com/akka/akka/commit/ced5aa7ddcac1408e08ed159da9a04fecfad18ed as a reference, however there are some slight changes which will be marked in comments to particular lines.
reviewed tested

opened by ataraxer 59
bump: metrics-core, metrics-jvm 4.2.13 (was 4.2.12)
Updates

io.dropwizard.metrics:metrics-core

io.dropwizard.metrics:metrics-jvm

from 4.2.12 to 4.2.13. GitHub Release Notes - Version Diff

I'll automatically update this PR to resolve conflicts as long as you don't change it yourself.

If you'd like to skip this version, you can just close this PR. If you have any feedback, just mention me in the comments below.

Configure Scala Steward for your repository with a .scala-steward.conf file.

Have a fantastic day writing Scala!

Adjust future updates

Add this to your .scala-steward.conf file to ignore future updates of this dependency:

updates.ignore = [ { groupId = "io.dropwizard.metrics" } ]

Or, add this to slow down future updates of this dependency:

dependencyOverrides = [{ pullRequests = { frequency = "@monthly" }, dependency = { groupId = "io.dropwizard.metrics" } }]

labels: test-library-update, early-semver-patch, semver-spec-patch, commit-count:1
dependency-change
opened by scala-steward 0
bump: sbt-assembly 2.1.0 (was 2.0.0)
Updates com.eed3si9n:sbt-assembly from 2.0.0 to 2.1.0. GitHub Release Notes - Version Diff

I'll automatically update this PR to resolve conflicts as long as you don't change it yourself.

If you'd like to skip this version, you can just close this PR. If you have any feedback, just mention me in the comments below.

Configure Scala Steward for your repository with a .scala-steward.conf file.

Have a fantastic day writing Scala!

Adjust future updates

Add this to your .scala-steward.conf file to ignore future updates of this dependency:

updates.ignore = [ { groupId = "com.eed3si9n", artifactId = "sbt-assembly" } ]

Or, add this to slow down future updates of this dependency:

dependencyOverrides = [{ pullRequests = { frequency = "@monthly" }, dependency = { groupId = "com.eed3si9n", artifactId = "sbt-assembly" } }]

labels: sbt-plugin-update, early-semver-minor, semver-spec-minor, commit-count:1
opened by scala-steward 0

Failed: EventSourcedBehaviorRetentionSpec

https://github.com/akka/akka/actions/runs/3709022163/jobs/6287193701

[12-16 00:49:16.125] [info] - must delete snapshots automatically, based on criteria *** FAILED *** (6 seconds, 70 milliseconds)
[22177](https://github.com/akka/akka/actions/runs/3709022163/jobs/6287193701#step:5:22178)
[12-16 00:49:16.125] [info]   java.lang.AssertionError: Timeout (6 seconds) during expectMessageClass waiting for class akka.persistence.typed.scaladsl.EventSourcedBehaviorRetentionSpec$WrappedSignal
[22178](https://github.com/akka/akka/actions/runs/3709022163/jobs/6287193701#step:5:22179)
[12-16 00:49:16.125] [info]   at akka.actor.testkit.typed.internal.TestProbeImpl.assertFail(TestProbeImpl.scala:399)
[22179](https://github.com/akka/akka/actions/runs/3709022163/jobs/6287193701#step:5:22180)
[12-16 00:49:16.126] [info]   at akka.actor.testkit.typed.internal.TestProbeImpl.expectMessageClass_internal(TestProbeImpl.scala:239)
[22180](https://github.com/akka/akka/actions/runs/3709022163/jobs/6287193701#step:5:22181)
[12-16 00:49:16.127] [info]   at akka.actor.testkit.typed.internal.TestProbeImpl.expectMessageType(TestProbeImpl.scala:218)
[22181](https://github.com/akka/akka/actions/runs/3709022163/jobs/6287193701#step:5:22182)
[12-16 00:49:16.127] [info]   at akka.persistence.typed.scaladsl.EventSourcedBehaviorRetentionSpec$WrappedSignalProbeAssert.expectSnapshotCompleted(EventSourcedBehaviorRetentionSpec.scala:98)
[22182](https://github.com/akka/akka/actions/runs/3709022163/jobs/6287193701#step:5:22183)
[12-16 00:49:16.127] [info]   at akka.persistence.typed.scaladsl.EventSourcedBehaviorRetentionSpec.$anonfun$new$17(EventSourcedBehaviorRetentionSpec.scala:287)

t:persistence failed

opened by johanandren 5

Failed: SnapshotTestKit

https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29602

[12-15 01:01:13.778] [info] - should test snapshot events with RetentionCriteria after sending commands *** FAILED *** (2 seconds, 19 milliseconds)
[29602](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29603)
[12-15 01:01:13.778] [info]   java.lang.AssertionError: assertion failed: Failed to persist NonEmptyState(abcdefghij), got None instead
[29603](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29604)
[12-15 01:01:13.778] [info]   at scala.runtime.Scala3RunTime$.assertFailed(Scala3RunTime.scala:8)
[29604](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29605)
[12-15 01:01:13.778] [info]   at akka.persistence.testkit.scaladsl.ExpectOps.$anonfun$5(TestOps.scala:148)
[29605](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29606)
[12-15 01:01:13.778] [info]   at akka.testkit.TestKitBase.poll$2(TestKit.scala:332)
[29606](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29607)
[12-15 01:01:13.778] [info]   at akka.testkit.TestKitBase.awaitAssert(TestKit.scala:349)
[29607](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29608)
[12-15 01:01:13.778] [info]   at akka.testkit.TestKitBase.awaitAssert$(TestKit.scala:159)
[29608](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29609)
[12-15 01:01:13.778] [info]   at akka.testkit.TestKit.awaitAssert(TestKit.scala:973)
[29609](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29610)
[12-15 01:01:13.778] [info]   at akka.persistence.testkit.scaladsl.ExpectOps.expectNextPersisted(TestOps.scala:150)
[29610](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29611)
[12-15 01:01:13.778] [info]   at akka.persistence.testkit.scaladsl.ExpectOps.expectNextPersisted$(TestOps.scala:116)
[29611](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29612)
[12-15 01:01:13.778] [info]   at akka.persistence.testkit.scaladsl.SnapshotTestKit.expectNextPersisted(PersistenceTestKit.scala:318)
[29612](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29613)
[12-15 01:01:13.778] [info]   at akka.persistence.testkit.scaladsl.ExpectOps.expectNextPersisted(TestOps.scala:135)
[29613](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29614)
[12-15 01:01:13.778] [info]   at akka.persistence.testkit.scaladsl.ExpectOps.expectNextPersisted$(TestOps.scala:116)
[29614](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29615)
[12-15 01:01:13.778] [info]   at akka.persistence.testkit.scaladsl.SnapshotTestKit.expectNextPersisted(PersistenceTestKit.scala:336)
[29615](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29616)
[12-15 01:01:13.778] [info]   at akka.persistence.testkit.scaladsl.CommonSnapshotTests.f$proxy34$1(CommonSnapshotTests.scala:556)
[29616](https://github.com/akka/akka/actions/runs/3699824735/jobs/6267595771#step:5:29617)
[12-15 01:01:13.778] [info]   at akka.persistence.testkit.scaladsl.CommonSnapshotTests.$init$$$anonfun$1$$anonfun$26(CommonSnapshotTests.scala:530)

failed

opened by johanandren 0

Initial state race condition in EventSourcedBehaviorTestKit
Reported by @azolotko

Is the underlying implementation a subject to race conditions? I have a test like the following that fails from time to time in a slow CI environment:

behaviorTestKit.initialize(initialState) val result = behaviorTestKit.runCommand(GetState(endpointId, _)) result.replyOfType[State] ==== initialState

The test fails because the returned result contains a default state instead of the provided initialState.

Originally posted by @azolotko in https://github.com/akka/akka/issues/31193#issuecomment-1340801816
t:persistence 0 - new t:testing
opened by johanandren 0

Failed: ClusterSpec

https://github.com/akka/akka/actions/runs/3555943136/jobs/5972924273#step:5:23764

JDK 17, Scala 2.12 Nightly

[11-27 01:01:38.585] [info] - must leave via CoordinatedShutdown.run when member status is Joining *** FAILED *** (1 second, 45 milliseconds)
[23764](https://github.com/akka/akka/actions/runs/3555943136/jobs/5972924273#step:5:23765)
[11-27 01:01:38.587] [info]   Leaving did not equal Exiting (ClusterSpec.scala:275)
[23765](https://github.com/akka/akka/actions/runs/3555943136/jobs/5972924273#step:5:23766)
[11-27 01:01:38.588] [info]   org.scalatest.exceptions.TestFailedException:
[23766](https://github.com/akka/akka/actions/runs/3555943136/jobs/5972924273#step:5:23767)
[11-27 01:01:38.588] [info]   at org.scalatest.matchers.MatchersHelper$.indicateFailure(MatchersHelper.scala:339)
[23767](https://github.com/akka/akka/actions/runs/3555943136/jobs/5972924273#step:5:23768)
[11-27 01:01:38.589] [info]   at org.scalatest.matchers.should.Matchers$AnyShouldWrapper.should(Matchers.scala:6922)
[23768](https://github.com/akka/akka/actions/runs/3555943136/jobs/5972924273#step:5:23769)
[11-27 01:01:38.589] [info]   at akka.cluster.ClusterSpec.$anonfun$new$29(ClusterSpec.scala:275)

t:cluster failed

opened by johanandren 0

Releases(v2.8.0-M3)

v2.8.0-M3(Dec 22, 2022)
What's Changed

build: Update gcp ghaction plugin for working auth by @johanandren in https://github.com/akka/akka/pull/31791

build: Multinode gke auth by @johanandren in https://github.com/akka/akka/pull/31792

build: Install gcloud auth plugin by @johanandren in https://github.com/akka/akka/pull/31793

build: Set USE_GKE_GCLOUD_AUTH_PLUGIN in multinode ci by @johanandren in https://github.com/akka/akka/pull/31794

Update gson to 2.10 by @scala-steward in https://github.com/akka/akka/pull/31741

fix: Less error logging, more retrying in ddata rememer entities by @johanandren in https://github.com/akka/akka/pull/31802

Preparations for external transport of replicated events by @johanandren in https://github.com/akka/akka/pull/31771

chore: safer EventEnvelope.toString by @patriknw in https://github.com/akka/akka/pull/31804

fix: SnapshotSerializeSpec test case that was never deterministic removed by @johanandren in https://github.com/akka/akka/pull/31805

Full Changelog: https://github.com/akka/akka/compare/v2.8.0-M2...v2.8.0-M3
Source code(tar.gz)
Source code(zip)
v2.8.0-M2(Dec 14, 2022)
What's Changed

chore: Adjust commit message recommendations by @patriknw in https://github.com/akka/akka/pull/31755

Update sbt-java-formatter to 0.8.0 by @scala-steward in https://github.com/akka/akka/pull/31742

ci: back to ancient version of setup-gcloud by @ennru in https://github.com/akka/akka/pull/31763

ci: permit checks and PR writes to attach surefire reports by @ennru in https://github.com/akka/akka/pull/31762

chore: Harden EventSourcedBehaviorRetentionSpec, #31623 by @patriknw in https://github.com/akka/akka/pull/31758

chore: fix jdk8 compilation errors in doc sampes by @patriknw in https://github.com/akka/akka/pull/31767

chore: Remove deprecated Classic Remoting, #31764 by @patriknw in https://github.com/akka/akka/pull/31765

chore: additional mima filters for Scala 3 by @patriknw in https://github.com/akka/akka/pull/31770

Update aeron-client, aeron-driver to 1.40.0 by @scala-steward in https://github.com/akka/akka/pull/31744

chore: Tests not compiling on 2.12 by @johanandren in https://github.com/akka/akka/pull/31773

chore: multi-node testkit throttle not implemented in Artery by @patriknw in https://github.com/akka/akka/pull/31774

docs: r2dbc in plugins with replicated es support by @johanandren in https://github.com/akka/akka/pull/31779

Update groupby doc scala by @pooriatgh in https://github.com/akka/akka/pull/31780

chore: port conflict in AeronStream tests, #31778 by @patriknw in https://github.com/akka/akka/pull/31787

perf: Skip delete snapshots in retention when plugin only keeps one snapshot by @patriknw in https://github.com/akka/akka/pull/31784

chore: improve some links (so they pass the link checker) by @ennru in https://github.com/akka/akka/pull/31781

Auto-select SRV lookup for the name lookup if entry looks like a srv name by @johanandren in https://github.com/akka/akka/pull/31727

feat: convenience factories for Scala Try to StatusReply transform by @johanandren in https://github.com/akka/akka/pull/31783

feat: Optimized mandatory attributes by @johanandren in https://github.com/akka/akka/pull/31777

fix: Follow up to #31777 mima filters for Scala 3 by @johanandren in https://github.com/akka/akka/pull/31789

fix: Only one retention cycle in progress at a time, #31785 by @patriknw in https://github.com/akka/akka/pull/31786

ci: Remove special-casing Scala 3 by @ennru in https://github.com/akka/akka/pull/31775

Special exception message for system.actorOf with a typed guardian by @leviramsey in https://github.com/akka/akka/pull/31768

New Contributors

@pooriatgh made their first contribution in https://github.com/akka/akka/pull/31780

Full Changelog: https://github.com/akka/akka/compare/v2.8.0-M1...v2.8.0-M2
Source code(tar.gz)
Source code(zip)
v2.8.0-M1(Nov 22, 2022)
What's Changed

MiMa for 2.7.0 and JDK9 classes by @johanandren in https://github.com/akka/akka/pull/31693

Update license change date for Akka 2.7.0 by @patriknw in https://github.com/akka/akka/pull/31700

Fix flaky EventSourcedBehaviorRetentionSpec, #31623 by @patriknw in https://github.com/akka/akka/pull/31703

Remove superflous ) in generated pids in tests by @patriknw in https://github.com/akka/akka/pull/31704

Use cos_containerd image in multi-node tests, #31698 by @patriknw in https://github.com/akka/akka/pull/31702

Update release issue template by @patriknw in https://github.com/akka/akka/pull/31701

=str Avoid subMaterialization when the provided recover source is empty. by @He-Pin in https://github.com/akka/akka/pull/31669

Harden RemoteFailureSpec, #31250 by @patriknw in https://github.com/akka/akka/pull/31709

Harden RememberEntitiesAndStartEntitySpec, #31221 by @patriknw in https://github.com/akka/akka/pull/31708

Harden ReliableDeliveryShardingSpec, #31263 by @patriknw in https://github.com/akka/akka/pull/31707

Increase timeout in OutboundIdleShutdownSpec, #30984 by @patriknw in https://github.com/akka/akka/pull/31706

=str Fix scala doc of Source#idleTimeout. by @He-Pin in https://github.com/akka/akka/pull/31713

chore: replace apidoc links; bump link validator by @ennru in https://github.com/akka/akka/pull/31699

!str Logging error instead of failing the keepAlive operator. by @He-Pin in https://github.com/akka/akka/pull/31712

Prepare for Akka 2.8 by @patriknw in https://github.com/akka/akka/pull/31723

Expiry of CRDT entries, #27683 by @patriknw in https://github.com/akka/akka/pull/31721

Fix release script typo by @johanandren in https://github.com/akka/akka/pull/31725

chore: renovate GH workflows by @ennru in https://github.com/akka/akka/pull/31730

ci: artifact filename quoting by @ennru in https://github.com/akka/akka/pull/31732

Add color to LogCapturing #31689 by @jackyscript in https://github.com/akka/akka/pull/31719

avoid integer value retention event version overflow. by @Roiocam in https://github.com/akka/akka/pull/31718

=doc Update java code sample of StatefulMap. by @He-Pin in https://github.com/akka/akka/pull/31696

=str code clean up in Sliding. by @He-Pin in https://github.com/akka/akka/pull/31714

Include roundtrip latency and seq nr in heartbeat debug log by @johanandren in https://github.com/akka/akka/pull/31726

ci: use Temurin JDKs everywhere by @ennru in https://github.com/akka/akka/pull/31734

Release lease on shard stop by @johanandren in https://github.com/akka/akka/pull/31716

Optimize props adapter by @johanandren in https://github.com/akka/akka/pull/31695

Update persistence-snapshot.md by @sebastian-alfers in https://github.com/akka/akka/pull/31738

Avoid submaterialization for lazy future and lazy single by @johanandren in https://github.com/akka/akka/pull/31735

Wildcard subscription of ddata changes by @patriknw in https://github.com/akka/akka/pull/31731

ci: update failure reporting address by @ennru in https://github.com/akka/akka/pull/31736

build: Drop OSGi support by @johanandren in https://github.com/akka/akka/pull/31747

=str Add test for not call onComplete twice when upstream complete. by @He-Pin in https://github.com/akka/akka/pull/31748

cp .jvmopts-ci instead of mv by @patriknw in https://github.com/akka/akka/pull/31749

ci: current gcloud action version by @ennru in https://github.com/akka/akka/pull/31750

Run DurableStateBehavior delete effect in same way as persist, #31752 by @patriknw in https://github.com/akka/akka/pull/31753

ci: current gcloud action in second spot by @ennru in https://github.com/akka/akka/pull/31751

Update sbt-assembly to 2.0.0 by @scala-steward in https://github.com/akka/akka/pull/31739

Update sbt-ci-release to 1.5.11 by @scala-steward in https://github.com/akka/akka/pull/31740

Update Scala Steward's PR naming by @ennru in https://github.com/akka/akka/pull/31754

New Contributors

@jackyscript made their first contribution in https://github.com/akka/akka/pull/31719

Full Changelog: https://github.com/akka/akka/compare/v2.7.0...v2.8.0-M1
Source code(tar.gz)
Source code(zip)
v2.7.0(Oct 19, 2022)
What's Changed

Latest for mima 2.6.20 by @patriknw in https://github.com/akka/akka/pull/31560

fix CLA links by @sebastian-alfers in https://github.com/akka/akka/pull/31562

Change license by @patriknw in https://github.com/akka/akka/pull/31561

more CLA fixes by @sebastian-alfers in https://github.com/akka/akka/pull/31566

Minor build preparation for 2.7.0-M1 by @patriknw in https://github.com/akka/akka/pull/31568

=str Update FlowMergeAllSpec because the merge order is undefined. by @He-Pin in https://github.com/akka/akka/pull/31550

Add mapWithResource by @He-Pin in https://github.com/akka/akka/pull/31361

doc: Note null being ignored in mapAsync/mapAsyncUnordered by @johanandren in https://github.com/akka/akka/pull/31581

MiMa settings for 2.7 by @patriknw in https://github.com/akka/akka/pull/31570

Enables Fortify SCA scans in support of SOC 2 compliance efforts by @grimlor in https://github.com/akka/akka/pull/31421

=str Update MapWithResourceSpec to request 1 to fix #31585. by @He-Pin in https://github.com/akka/akka/pull/31591

Add FOSSA policy check to nightly by @patriknw in https://github.com/akka/akka/pull/31594

Deprecate old api in streams testkit, #29850 by @patriknw in https://github.com/akka/akka/pull/31596

Migration guide 2.7 by @patriknw in https://github.com/akka/akka/pull/31597

Fix broken link in stream customize by @johanandren in https://github.com/akka/akka/pull/31588

Try to fix fossa error by @patriknw in https://github.com/akka/akka/pull/31599

=str Reduce one field in MapAsyncUnordered. by @He-Pin in https://github.com/akka/akka/pull/31574

=str Fold InHandler and OutHandler for operator ActorRefSource. by @He-Pin in https://github.com/akka/akka/pull/31544

=str Fold InHandler and OutHandler for operator Scan. by @He-Pin in https://github.com/akka/akka/pull/31535

=str Add IterableSource. by @He-Pin in https://github.com/akka/akka/pull/31372

Update Jackson to 2.13.4, #31097 by @patriknw in https://github.com/akka/akka/pull/31595

Update aeron-client, aeron-driver to 1.39.0 by @scala-steward in https://github.com/akka/akka/pull/31482

Update metrics-core, metrics-jvm to 4.2.12 by @scala-steward in https://github.com/akka/akka/pull/31564

=act Make akka compiles on scala 3.1.3 & 3.2.0 by @He-Pin in https://github.com/akka/akka/pull/31578

stream: use ConcurrentHashMap to track in-progress async callbacks by @jrudolph in https://github.com/akka/akka/pull/29636

fix: mima filter for 29557-GraphStage-changes by @pvlugter in https://github.com/akka/akka/pull/31607

+str Add combine seq method to Source and Sink by @He-Pin in https://github.com/akka/akka/pull/31345

=str Fold InHandler and outHandler for UniqueBidiKillSwitchStage. by @He-Pin in https://github.com/akka/akka/pull/31534

little Refactoring to unfoldResource by @He-Pin in https://github.com/akka/akka/pull/31572

=str Fold InHandler and OutHandler for operator WireTap. by @He-Pin in https://github.com/akka/akka/pull/31533

=str Fold InHandler and OutHandler in RecoverWith operator. by @He-Pin in https://github.com/akka/akka/pull/31532

Change default persistence plugin-dispatcher, #31058 by @patriknw in https://github.com/akka/akka/pull/31598

Custom stash capacity per entity (EventSourced and Durable) by @sebastian-alfers in https://github.com/akka/akka/pull/31479

typed javadsl: introduce AbstractOnMessageBehavior by @leviramsey in https://github.com/akka/akka/pull/31603

Fix maximumObjectLength check in JsonFraming, #31569 by @patriknw in https://github.com/akka/akka/pull/31600

main branch is now for akka 2.7 dev by @pjfanning in https://github.com/akka/akka/pull/31618

add missing .withAllocationStrategy(ExternalShardAllocationStrategy) example for Java by @michael-read in https://github.com/akka/akka/pull/31592

=str Use java.util.function.* in mapWithResource instead. by @He-Pin in https://github.com/akka/akka/pull/31611

!str Mark SubFlow and SubSource final. by @He-Pin in https://github.com/akka/akka/pull/31605

Update asn-one to 0.6.0 by @scala-steward in https://github.com/akka/akka/pull/30763

=sbt Bump reactive-stream-version to 1.0.4 by @He-Pin in https://github.com/akka/akka/pull/31424

fix: Compare required RC and M versions if present by @johanandren in https://github.com/akka/akka/pull/31631

Correction of docs for pruning-marker-time-to-live by @patriknw in https://github.com/akka/akka/pull/31635

chore: Silence some serializer warnings by @johanandren in https://github.com/akka/akka/pull/31632

Slight optimization of SupervisedGraphStage by @johanandren in https://github.com/akka/akka/pull/31633

fix: Replaying a replicated event sourced actor from snapshot caused bug by @johanandren in https://github.com/akka/akka/pull/31645

Change doc wording of oss by @patriknw in https://github.com/akka/akka/pull/31651

=sbt Bump Scala version to 2.12.17 & 2.13.10, sbt to 1.7.2 by @He-Pin in https://github.com/akka/akka/pull/31648

=str Make SingleConsumerMultiProducer the default mailbox for stream. by @He-Pin in https://github.com/akka/akka/pull/31620

!str filter out elements without demands for Flow#collect operator. by @He-Pin in https://github.com/akka/akka/pull/31617

fix: Don't double close on cancel in statefulMap by @johanandren in https://github.com/akka/akka/pull/31630

chore: Bump jackson databind by @johanandren in https://github.com/akka/akka/pull/31661

=sbt Just use -release 8 for build as starting Scala 2.12.17 always… by @He-Pin in https://github.com/akka/akka/pull/31652

=str Add dedicated stream timeout exceptions for timeout related oper… by @He-Pin in https://github.com/akka/akka/pull/31640

Remove link to Akka Cloud Platform by @patriknw in https://github.com/akka/akka/pull/31662

=str Make use of applyOrElse in MapError operator. by @He-Pin in https://github.com/akka/akka/pull/31642

=str Make use of OptionVal in Recover operator. by @He-Pin in https://github.com/akka/akka/pull/31643

Move fossa validation to separate workflow by @patriknw in https://github.com/akka/akka/pull/31665

Revert "!str filter out elements without demands for Flow#collect operator" by @patriknw in https://github.com/akka/akka/pull/31667

Jackson 2.13.4.2 by @patriknw in https://github.com/akka/akka/pull/31668

Implement effectful ask in typed BehaviorTestKit by @leviramsey in https://github.com/akka/akka/pull/30050

fix: emitting DeletedDurableState for deleted objects by @aludwiko in https://github.com/akka/akka/pull/31678

fix: Record timestamp should not be reused by @aludwiko in https://github.com/akka/akka/pull/31683

Add ability to create unpersistent versions of persistent behaviors by @leviramsey in https://github.com/akka/akka/pull/31464

fix: Unpersistent now compiling on 2.12 by @johanandren in https://github.com/akka/akka/pull/31684

Document add-opens flags for Java 17, #31087 by @patriknw in https://github.com/akka/akka/pull/31685

fix: Unpersistent order of event application by @leviramsey in https://github.com/akka/akka/pull/31686

chore(docs): fix some broken links by @ennru in https://github.com/akka/akka/pull/31688

Remove dotty serial version uid plugin second try by @johanandren in https://github.com/akka/akka/pull/31056

docs: Fix some api doc links #31641 by @johanandren in https://github.com/akka/akka/pull/31687

Add support for asking the BehaviorTestKit by @leviramsey in https://github.com/akka/akka/pull/31673

=str Optimize concat for javadsl.Source.empty. by @He-Pin in https://github.com/akka/akka/pull/31675

Compile persistence-testkit with Scala 2.12 by @patriknw in https://github.com/akka/akka/pull/31691

Fix RecipeAdhocSource test, #31674 by @patriknw in https://github.com/akka/akka/pull/31690

See also 2.7.0 milestone on github.

Full Changelog: https://github.com/akka/akka/compare/v2.6.20...v2.7.0

Credits

For this release we had the help of 12 committers – thank you all very much!

commits added removed 24 1657 325 kerr 20 1018 1883 Patrik Nordwall 11 269 161 Johan Andrén 5 3067 112 Levi Ramsey 3 206 33 Sebastian Alfers 2 30 5 Andrzej Ludwikowski 1 105 3 Jack Pines 1 24 29 Johannes Rudolph 1 8 8 Enno Runne 1 5 1 Michael Read / Principal Consultant at Lightbend, Inc 1 1 1 PJ Fanning 1 0 0 Peter Vlugter

New Contributors

@grimlor made their first contribution in https://github.com/akka/akka/pull/31421

@michael-read made their first contribution in https://github.com/akka/akka/pull/31592

@aludwiko made their first contribution in https://github.com/akka/akka/pull/31678

Source code(tar.gz)
Source code(zip)
v2.7.0-M5(Oct 14, 2022)
What's Changed

Revert "!str filter out elements without demands for Flow#collect operator" by @patriknw in https://github.com/akka/akka/pull/31667

Full Changelog: https://github.com/akka/akka/compare/v2.7.0-M4...v2.7.0-M5
Source code(tar.gz)
Source code(zip)
v2.7.0-M4(Oct 14, 2022)
What's Changed

Slight optimization of SupervisedGraphStage by @johanandren in https://github.com/akka/akka/pull/31633

fix: Replaying a replicated event sourced actor from snapshot caused bug by @johanandren in https://github.com/akka/akka/pull/31645

Change doc wording of oss by @patriknw in https://github.com/akka/akka/pull/31651

=sbt Bump Scala version to 2.12.17 & 2.13.10, sbt to 1.7.2 by @He-Pin in https://github.com/akka/akka/pull/31648

=str Make SingleConsumerMultiProducer the default mailbox for stream. by @He-Pin in https://github.com/akka/akka/pull/31620

!str filter out elements without demands for Flow#collect operator. by @He-Pin in https://github.com/akka/akka/pull/31617

fix: Don't double close on cancel in statefulMap by @johanandren in https://github.com/akka/akka/pull/31630

chore: Bump jackson databind by @johanandren in https://github.com/akka/akka/pull/31661

=sbt Just use -release 8 for build as starting Scala 2.12.17 always… by @He-Pin in https://github.com/akka/akka/pull/31652

=str Add dedicated stream timeout exceptions for timeout related oper… by @He-Pin in https://github.com/akka/akka/pull/31640

Remove link to Akka Cloud Platform by @patriknw in https://github.com/akka/akka/pull/31662

=str Make use of applyOrElse in MapError operator. by @He-Pin in https://github.com/akka/akka/pull/31642

=str Make use of OptionVal in Recover operator. by @He-Pin in https://github.com/akka/akka/pull/31643

Move fossa validation to separate workflow by @patriknw in https://github.com/akka/akka/pull/31665

Full Changelog: https://github.com/akka/akka/compare/v2.7.0-M3...v2.7.0-M4
Source code(tar.gz)
Source code(zip)
v2.7.0-M3(Sep 30, 2022)
What's Changed

fix: Compare required RC and M versions if present by @johanandren in https://github.com/akka/akka/pull/31631

Correction of docs for pruning-marker-time-to-live by @patriknw in https://github.com/akka/akka/pull/31635

chore: Silence some serializer warnings by @johanandren in https://github.com/akka/akka/pull/31632

Full Changelog: https://github.com/akka/akka/compare/v2.7.0-M2...v2.7.0-M3
Source code(tar.gz)
Source code(zip)
v2.7.0-M2(Sep 26, 2022)
What's Changed

=str Update FlowMergeAllSpec because the merge order is undefined. by @He-Pin in https://github.com/akka/akka/pull/31550

Add mapWithResource by @He-Pin in https://github.com/akka/akka/pull/31361

doc: Note null being ignored in mapAsync/mapAsyncUnordered by @johanandren in https://github.com/akka/akka/pull/31581

MiMa settings for 2.7 by @patriknw in https://github.com/akka/akka/pull/31570

Enables Fortify SCA scans in support of SOC 2 compliance efforts by @grimlor in https://github.com/akka/akka/pull/31421

=str Update MapWithResourceSpec to request 1 to fix #31585. by @He-Pin in https://github.com/akka/akka/pull/31591

Add FOSSA policy check to nightly by @patriknw in https://github.com/akka/akka/pull/31594

Deprecate old api in streams testkit, #29850 by @patriknw in https://github.com/akka/akka/pull/31596

Migration guide 2.7 by @patriknw in https://github.com/akka/akka/pull/31597

Fix broken link in stream customize by @johanandren in https://github.com/akka/akka/pull/31588

Try to fix fossa error by @patriknw in https://github.com/akka/akka/pull/31599

=str Reduce one field in MapAsyncUnordered. by @He-Pin in https://github.com/akka/akka/pull/31574

=str Fold InHandler and OutHandler for operator ActorRefSource. by @He-Pin in https://github.com/akka/akka/pull/31544

=str Fold InHandler and OutHandler for operator Scan. by @He-Pin in https://github.com/akka/akka/pull/31535

=str Add IterableSource. by @He-Pin in https://github.com/akka/akka/pull/31372

Update Jackson to 2.13.4, #31097 by @patriknw in https://github.com/akka/akka/pull/31595

Update aeron-client, aeron-driver to 1.39.0 by @scala-steward in https://github.com/akka/akka/pull/31482

Update metrics-core, metrics-jvm to 4.2.12 by @scala-steward in https://github.com/akka/akka/pull/31564

=act Make akka compiles on scala 3.1.3 & 3.2.0 by @He-Pin in https://github.com/akka/akka/pull/31578

stream: use ConcurrentHashMap to track in-progress async callbacks by @jrudolph in https://github.com/akka/akka/pull/29636

fix: mima filter for 29557-GraphStage-changes by @pvlugter in https://github.com/akka/akka/pull/31607

+str Add combine seq method to Source and Sink by @He-Pin in https://github.com/akka/akka/pull/31345

=str Fold InHandler and outHandler for UniqueBidiKillSwitchStage. by @He-Pin in https://github.com/akka/akka/pull/31534

little Refactoring to unfoldResource by @He-Pin in https://github.com/akka/akka/pull/31572

=str Fold InHandler and OutHandler for operator WireTap. by @He-Pin in https://github.com/akka/akka/pull/31533

=str Fold InHandler and OutHandler in RecoverWith operator. by @He-Pin in https://github.com/akka/akka/pull/31532

Change default persistence plugin-dispatcher, #31058 by @patriknw in https://github.com/akka/akka/pull/31598

Custom stash capacity per entity (EventSourced and Durable) by @sebastian-alfers in https://github.com/akka/akka/pull/31479

typed javadsl: introduce AbstractOnMessageBehavior by @leviramsey in https://github.com/akka/akka/pull/31603

Fix maximumObjectLength check in JsonFraming, #31569 by @patriknw in https://github.com/akka/akka/pull/31600

main branch is now for akka 2.7 dev by @pjfanning in https://github.com/akka/akka/pull/31618

add missing .withAllocationStrategy(ExternalShardAllocationStrategy) example for Java by @michael-read in https://github.com/akka/akka/pull/31592

=str Use java.util.function.* in mapWithResource instead. by @He-Pin in https://github.com/akka/akka/pull/31611

!str Mark SubFlow and SubSource final. by @He-Pin in https://github.com/akka/akka/pull/31605

Update asn-one to 0.6.0 by @scala-steward in https://github.com/akka/akka/pull/30763

=sbt Bump reactive-stream-version to 1.0.4 by @He-Pin in https://github.com/akka/akka/pull/31424

New Contributors

@grimlor made their first contribution in https://github.com/akka/akka/pull/31421

@michael-read made their first contribution in https://github.com/akka/akka/pull/31592

Full Changelog: https://github.com/akka/akka/compare/v2.7.0-M1...v2.7.0-M2
Source code(tar.gz)
Source code(zip)
v2.7.0-M1(Sep 9, 2022)
What's Changed

Latest for mima 2.6.20 by @patriknw in https://github.com/akka/akka/pull/31560

fix CLA links by @sebastian-alfers in https://github.com/akka/akka/pull/31562

Change license by @patriknw in https://github.com/akka/akka/pull/31561

more CLA fixes by @sebastian-alfers in https://github.com/akka/akka/pull/31566

Minor build preparation for 2.7.0-M1 by @patriknw in https://github.com/akka/akka/pull/31568

Full Changelog: https://github.com/akka/akka/compare/v2.6.20...v2.7.0-M1
Source code(tar.gz)
Source code(zip)
v2.6.20(Sep 6, 2022)

https://akka.io/blog/news/2022/09/06/akka-2.6.20-released
Source code(tar.gz)
Source code(zip)
v2.6.19(Mar 21, 2022)

https://akka.io/blog/news/2022/03/21/akka-2.6.19-released
Source code(tar.gz)
Source code(zip)
v2.6.18(Dec 20, 2021)

Source code(tar.gz)
Source code(zip)
v2.6.17(Oct 15, 2021)

Source code(tar.gz)
Source code(zip)
v2.6.16(Aug 26, 2021)

https://akka.io/blog/news/2021/08/19/akka-2.6.16-released
Source code(tar.gz)
Source code(zip)
v2.6.15(Jun 10, 2021)

https://akka.io/blog/news/2021/06/10/akka-2.6.15-released
Source code(tar.gz)
Source code(zip)
v2.6.14(Apr 8, 2021)

https://akka.io/blog/news/2021/04/08/akka-2.6.14-released
Source code(tar.gz)
Source code(zip)
v2.6.13(Feb 23, 2021)

https://akka.io/blog/news/2021/02/23/akka-2.6.13-released
Source code(tar.gz)
Source code(zip)
v2.6.12(Feb 1, 2021)

https://akka.io/blog/news/2021/01/28/akka-2.6.12-released
Source code(tar.gz)
Source code(zip)
v2.6.11(Jan 15, 2021)

https://akka.io/blog/news/2021/01/15/akka-2.6.11-released
Source code(tar.gz)
Source code(zip)
v2.6.10(Oct 9, 2020)

https://akka.io/blog/news/2020/10/09/akka-2.6.10-released
Source code(tar.gz)
Source code(zip)
v2.6.9(Sep 10, 2020)

https://akka.io/blog/news/2020/09/09/akka-2.6.9-released
Source code(tar.gz)
Source code(zip)
v2.6.8(Aug 5, 2020)

https://akka.io/blog/news/2020/07/16/akka-2.6.8-released

Released on 2020-07-16
Source code(tar.gz)
Source code(zip)
v2.6.7(Jul 13, 2020)

https://akka.io/blog/news/2020/07/10/akka-2.6.7-released
Source code(tar.gz)
Source code(zip)
v2.6.6(Jul 13, 2020)

https://akka.io/blog/news/2020/06/08/akka-2.6.6-released-split-brain-resolver
Source code(tar.gz)
Source code(zip)
v2.6.5(May 4, 2020)

https://akka.io/blog/news/2020/04/30/akka-2.6.5-released
Source code(tar.gz)
Source code(zip)
v2.6.4(Mar 19, 2020)

https://akka.io/blog/news/2020/03/13/akka-2.6.4-released
Source code(tar.gz)
Source code(zip)
v2.6.1(Jan 6, 2020)

https://akka.io/blog/news/2019/12/06/akka-2.6.1-released
Source code(tar.gz)
Source code(zip)
v2.6.0-M2(May 24, 2019)

Source code(tar.gz)
Source code(zip)
v2.5.23(May 21, 2019)

Source code(tar.gz)
Source code(zip)
v2.6.0-M1(May 21, 2019)

Source code(tar.gz)
Source code(zip)