Skip to main content

Apache Kafka

Install package​

dotnet add package TransactionalBox.Kafka

Outbox​

Register​

builder.Services.AddTransactionalBox(x =>
{
    x.AddOutbox(
        storage => ...,
        transport => transport.UseKafka(settings => settings.BootstrapServers = bootstrapServers)
    );
});

Inbox​

Register​

builder.Services.AddTransactionalBox(x =>
{
    x.AddInbox(
        storage => ...,
        transport => transport.UseKafka(settings => settings.BootstrapServers = bootstrapServers)
    );
});