kafka-aspnet

AspNetCore.Kafka

Features

Registration

Extended registration

Handlers

Declare handler with attribute

Derive your handler from `IMessageHandler` interface

Derive your handler from `IMessageHandler<TContract>` interface

Derive your handler from `IMessageHandler<TContract>` interface without `IMessage` additonal properties

Message contract declaration

`IMessage` wrapper

Shutdown consumption

Fluent subscription

Simple handler

Pipeline

Change consumption offset

Fluent

Message Offset attribute

Configuration

Message processing pipeline

Batches, Buffer, Commit/Store and Parallel execution per partition

Configure all in appsettings.json

Producing messages

Keys for produced messages

Explicit keys

Key property name in message declaration:

[MessageKey] attribute (preferred):

Interceptors

In-memory broker for Consumer/Producer mocking

Metrics

Configuration

Message configuration properties

Sample