dotnet-kafka-parallel-consumer

This sample uses .NET Channels to create in-memory queues to support one worker per Kafka topic partition.

Requirements

• .NET 6
• Docker

Quickstart

Start Kafka:

docker-compose up

Run the Worker:

dotnet run

Producing sample messages

I really like VSCode jeppeandersen.vscode-kafka extension to manually interact with Kafka. The file producer.kafka contains some code that the extension uses to generate sample messages.