Koto.Messaging.Wolverine 0.1.0-preview.5

This is a prerelease version of Koto.Messaging.Wolverine.

dotnet add package Koto.Messaging.Wolverine --version 0.1.0-preview.5

NuGet\Install-Package Koto.Messaging.Wolverine -Version 0.1.0-preview.5

This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.

<PackageReference Include="Koto.Messaging.Wolverine" Version="0.1.0-preview.5" />

For projects that support PackageReference, copy this XML node into the project file to reference the package.

<PackageVersion Include="Koto.Messaging.Wolverine" Version="0.1.0-preview.5" />
                    

                            Directory.Packages.props

<PackageReference Include="Koto.Messaging.Wolverine" />
                    

                            Project file

For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.

paket add Koto.Messaging.Wolverine --version 0.1.0-preview.5

The NuGet Team does not provide support for this client. Please contact its maintainers for support.

#r "nuget: Koto.Messaging.Wolverine, 0.1.0-preview.5"

#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.

#:package Koto.Messaging.Wolverine@0.1.0-preview.5

#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.

#addin nuget:?package=Koto.Messaging.Wolverine&version=0.1.0-preview.5&prerelease
                    

                            Install as a Cake Addin

#tool nuget:?package=Koto.Messaging.Wolverine&version=0.1.0-preview.5&prerelease
                    

                            Install as a Cake Tool

The NuGet Team does not provide support for this client. Please contact its maintainers for support.

Koto.Messaging.Wolverine

Wolverine + Kafka implementation of Koto messaging abstractions.

What's included

Type	Purpose
`WolverineIntegrationEventPublisher`	`IIntegrationEventPublisher` → `IMessageBus.PublishAsync`
`WolverineIntegrationCommandDispatcher`	`IIntegrationCommandDispatcher` → fire-and-forget + request/reply
`IntegrationEventConsumerBase<TEvent>`	Idempotent Kafka consumer base with DLQ routing
`IntegrationCommandConsumerBase<TCommand>`	Kafka command consumer base with structured logging
`CorrelationIdMiddleware`	Propagates Wolverine `Envelope.CorrelationId` via `CorrelationContext`
`IdempotencyMiddleware`	Policy-level deduplication (alternative to the consumer base check)
`IProcessedMessageStore`	Idempotency store abstraction (in-memory default, plug in PostgreSQL for production)

Setup

// Program.cs
builder.Services.AddKotoWolverine(opts =>
{
    opts.RequestReplyTimeout = TimeSpan.FromSeconds(10);
    opts.IdempotencyWindow = TimeSpan.FromHours(24);
});

builder.Host.UseWolverine(opts =>
{
    opts.UseKafka("localhost:9092").AutoProvisionTopics();

    // Route outbound events to topics
    opts.PublishMessage<OrderPlacedEvent>().ToKafkaTopic("orders.order-placed");

    // Listen for inbound events
    opts.ListenToKafkaTopic("payments.payment-processed").ProcessInline();

    // Propagate correlation IDs on every handler
    opts.Policies.AddMiddleware<CorrelationIdMiddleware>();

    // Auto-dispatch domain events from EF Core aggregates to the outbox
    opts.PublishDomainEventsFromEntityFrameworkCore<IHasDomainEvents, IDomainEvent>(
        e => e.DomainEvents);
});

Kafka topic naming convention

Event topics: {service}.{event-type} → orders.order-placed
Consumer groups: {consuming-service}.{event-type}-consumer

Implementing a consumer

public sealed class PaymentProcessedConsumer
    : IntegrationEventConsumerBase<PaymentProcessedEvent>
{
    public PaymentProcessedConsumer(
        IProcessedMessageStore store,
        ILogger<IntegrationEventConsumerBase<PaymentProcessedEvent>> logger)
        : base(store, logger) { }

    protected override async Task ConsumeAsync(PaymentProcessedEvent @event, CancellationToken ct)
    {
        // domain logic here
    }
}

Production idempotency store

Replace InMemoryProcessedMessageStore with a durable store:

builder.Services.AddScoped<IProcessedMessageStore, PostgresProcessedMessageStore>();

Product	Compatible and additional computed target framework versions.
.NET	net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed.

Compatible target framework(s)

Included target framework(s) (in package)

Learn more about Target Frameworks and .NET Standard.

net10.0
- Koto.Application (>= 0.1.0-preview.5)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.7)
- Microsoft.Extensions.Options (>= 10.0.7)
- WolverineFx (>= 5.39.0)
- WolverineFx.Kafka (>= 5.39.0)

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version	Downloads	Last Updated
0.1.0-preview.5	38	5/13/2026
0.1.0-preview.4	34	5/13/2026
0.1.0-preview.3	34	5/13/2026