Automated Akka.NET cluster formation for .NET Aspire. Configure your cluster topology in the AppHost, and each service replica will automatically discover peers, form a cluster, and report health status.

using Aaron.Akka.Aspire.Hosting;

var builder = DistributedApplication.CreateBuilder(args);

var redis = builder.AddRedis("akka-discovery");

var akka = builder.AddAkka("my-cluster")
    .WithClustering(redis);

builder.AddProject<Projects.MyService>("service")
    .WithHttpEndpoint(name: "http")
    .WithReplicas(3)
    .WithReference(akka);

builder.Build().Run();

using Aaron.Akka.Aspire;
using Aaron.Akka.Discovery.Redis;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddAkka("MySystem", (akkaBuilder, sp) =>
{
    akkaBuilder.WithAspireClusterBootstrap(sp,
        configureDiscovery: (b, config) =>
        {
            var redisConn = config.GetConnectionString("akka-discovery");
            if (!string.IsNullOrEmpty(redisConn))
                b.WithRedisDiscovery(redisConn, config["Akka:Cluster:ServiceName"]);
        },
        clusterConfigure: c => c.Roles = ["my-service"]);
});

builder.Services.AddHealthChecks();
var app = builder.Build();

app.MapHealthChecks("/healthz");
app.MapGet("/", () => "Hello from Akka.NET!");
app.Run();

WithAspireClusterBootstrap configures Akka.Remote, Akka.Cluster, Akka.Management, Cluster Bootstrap, and health checks from the environment variables that the hosting package injects. The configureDiscovery callback wires up the discovery plugin using the same IConfiguration that Aspire populates. No manual HOCON needed.

The hosting package (WithReference(akka)) injects environment variables into each service replica:

• Akka__Cluster__Enabled - enables clustering
• Akka__Cluster__RemotePort / Akka__Cluster__ManagementPort - unique ports per replica
• Akka__Cluster__PublicHostName / Akka__Cluster__ServiceName - discovery identity
• Akka__Cluster__RequiredContactPointsNr - derived from replica count
• Akka__Cluster__Clustering__ProviderType - auto-detected from the resource type (e.g. Redis, AzureTableStorage)
• Akka__Cluster__Clustering__ConnectionStringName - the Aspire resource name for the discovery backend
• Connection string for the discovery backend (e.g. ConnectionStrings__akka-discovery)

The service-side bootstrap reads these via IConfiguration, configures the full Akka.NET cluster stack, and uses the discovery plugin to find other replicas. Cluster Bootstrap's SelfAwareJoinDecider handles initial seed node election.

• Redis (Aaron.Akka.Discovery.Redis) - each node registers in Redis with a heartbeat
• Azure Table Storage (Akka.Discovery.Azure) - uses Azure Table Storage for node registration
• Kubernetes (Akka.Discovery.KubernetesApi) - queries the Kubernetes API for pod endpoints
• Config - static seed nodes (default fallback)

The configureDiscovery callback makes it straightforward to swap discovery providers between environments. Only the AppHost and the callback change -- the rest of the service code stays identical.

AppHost:

var storage = builder.AddAzureStorage("azure-storage").RunAsEmulator();
var tables = storage.AddTables("akka-discovery");

var akka = builder.AddAkka("my-cluster")
    .WithClustering(tables);

Service:

akkaBuilder.WithAspireClusterBootstrap(sp,
    configureDiscovery: (b, config) =>
    {
        var azureConn = config.GetConnectionString("akka-discovery");
        if (!string.IsNullOrEmpty(azureConn))
            b.WithAzureDiscovery(azureConn, config["Akka:Cluster:ServiceName"]);
    },
    clusterConfigure: c => c.Roles = ["my-service"]);

Service:

akkaBuilder.WithAspireClusterBootstrap(sp,
    configureDiscovery: (b, config) =>
    {
        b.WithKubernetesDiscovery();
    },
    clusterConfigure: c => c.Roles = ["my-service"]);

See the samples/ directory for complete working examples with Redis and Azure Table Storage.

• Akka.NET Clustering - how Akka.NET clusters work, membership lifecycle, and seed node discovery
• Akka.Management - HTTP management endpoint and Cluster Bootstrap for automated cluster formation
• Akka.Hosting - IServiceCollection integration for configuring Akka.NET without raw HOCON
• .NET Aspire - orchestration, service discovery, and telemetry for distributed .NET apps

dotnet tool restore
dotnet build -c Release
dotnet test -c Release
dotnet pack -c Release -o ./bin/nuget

Integration tests require Docker (they spin up a Redis container via Aspire).

Apache-2.0