rheader/net-kafka-connector

Connector for running .Net clients to process messages from Kafka broker

Base description

Basic connectors for easy and fast connection of your consumers and producers to Kafka instances

Usage Kafka

Start docker-compose

Go to Kafka UI [localhost:8080]()

Usage producer

Basic steps:

Create producer instance with `ReactiveInstance` sender object

builder.Services.AddKafkaProducer<string, ReactiveInstance>(options =>
{
    options.Topic = "base_";
    options.BootstrapServers = "localhost:9092,localhost:9093,localhost:9094";
});

Usage producer from DI

private readonly IKafkaBus<string, ReactiveInstance> _bus;
await _bus.PublishAsync(Key, Body);

Usage Consumer

Basic steps:

Create consumer instance with ReactiveInstance consumer object
and ConsumerHandler

builder.Services.AddKafkaConsumer<string, ReactiveInstance, ReactiveHandler>
(options =>
{
    options.Topic = "base_";
    options.BootstrapServers = "localhost:9092,localhost:9093,localhost:9094";
    options.GroupId = "base_group";
});

Implemented consumer handler

public class ReactiveHandler : IConsumerHandler<string, ReactiveInstance>