👁 Image
Kuestenlogik.Akka.Surgewave.Persistence 0.3.4

Akka.Surgewave

Akka.NET integration packages for Surgewave — Akka.Streams sources/sinks/flows and an Akka.Persistence journal + snapshot store + read journal, both backed by Surgewave.

Two NuGet packages ship from this repository:

Naming. The Akka.* prefix on nuget.org is verified-reserved by the Akka.NET team (owner Akka). Third-party plugins either get donated to that account or ship under their own brand. Surgewave takes the second route — the Kuestenlogik.Akka.Surgewave.{Streams,Persistence} ids and namespaces sit under the Kuestenlogik brand. The .Surgewave. segment between Akka and Streams/Persistence is deliberate: it means our namespace never contains the substring Akka.Streams or Akka.Persistence, so the C# compiler can't confuse using Akka.Streams.Dsl; (the external Akka.NET package) with our own namespace tree.

Kuestenlogik.Akka.Surgewave.Streams

dotnet add package Kuestenlogik.Akka.Surgewave.Streams

using Kuestenlogik.Akka.Surgewave.Streams;

Features

• PlainSource / CommittableSource — Consumer sources with backpressure and offset commit
• PlainSink / FlexiFlow — Producer stages with delivery feedback and passthrough support
• Transactional — End-to-end exactly-once consume-transform-produce pipelines
• Committer — Batched offset commits with configurable intervals
• Schema Registry — Typed serialization/deserialization via Surgewave Schema Registry
• Partitioned Sources — Sub-source per partition for partition-local processing

Quick Start

var control = SurgewaveConsumer
 .CommittableSource(consumerSettings, Subscriptions.Topics("orders"))
 .SelectAsync(10, async msg =>
 {
 await ProcessOrder(msg.Record.Key, msg.Record.Value);
 return msg.CommittableOffset;
 })
 .ToMaterialized(
 Committer.Sink(CommitterSettings.Create(system)),
 DrainingControl<Done>.Create)
 .Run(materializer);

Kuestenlogik.Akka.Surgewave.Persistence

dotnet add package Kuestenlogik.Akka.Surgewave.Persistence

using Kuestenlogik.Akka.Surgewave.Persistence;

Features

• AsyncWriteJournal — Surgewave-backed event journal with index-based fast replay
• SnapshotStore — Compacted topic for automatic snapshot lifecycle
• Persistence Query — EventsByPersistenceId, EventsByTag, AllEvents (live + current)
• Two Serialization Modes — Opaque (Akka serializer passthrough) and Schema Registry (Protobuf/Avro/JSON)
• Schema Registry Integration — Events become first-class citizens in the Surgewave ecosystem
• Exactly-Once Semantics — Optional transactional writes for AtomicWrite guarantees
• Multi-Tenancy — Topic prefix support for multiple actor systems on the same cluster

Quick Start

builder.Services.AddAkka("my-system", (akkaBuilder, sp) =>
{
 akkaBuilder
 .WithSurgewavePersistence(surgewave =>
 {
 surgewave.BootstrapServers = "localhost:9092";
 surgewave.Journal.Topic = "akka-journal";
 surgewave.Snapshots.Topic = "akka-snapshots";
 surgewave.SchemaRegistry.Url = "http://localhost:8081";
 })
 .WithSurgewaveReadJournal();
});

History

This repository consolidates the previously separate Akka.Streams.Surgewave and Akka.Persistence.Surgewave repositories (each at v0.1.1 on nuget.org under Kuestenlogik.Akka.Streams.Surgewave / Kuestenlogik.Akka.Persistence.Surgewave). v0.3.0 ships from this combined repo with the ids above; the old repos are archived with a pointer to this one. (A short-lived v0.2.0 used the interim ids Kuestenlogik.Surgewave.AkkaStreams / .AkkaPersistence; those are unlisted in favour of the Kuestenlogik.Akka.Surgewave.* ids.)

License

Apache-2.0