This project has moved tohttps://github.com/confluentinc/confluent-kafka-dotnet and is now being maintained by Confluent

rdkafka-dotnet - C# Apache Kafka client

Usage

Examples

Producing messages

using(Producerproducer=newProducer("127.0.0.1:9092"))using(Topictopic=producer.Topic("testtopic")){byte[]data=Encoding.UTF8.GetBytes("Hello RdKafka");DeliveryReportdeliveryReport=awaittopic.Produce(data);Console.WriteLine($"Produced to Partition:{deliveryReport.Partition}, Offset:{deliveryReport.Offset}");}

Consuming messages

varconfig=newConfig(){GroupId="example-csharp-consumer"};using(varconsumer=newEventConsumer(config,"127.0.0.1:9092")){consumer.OnMessage+=(obj,msg)=>{stringtext=Encoding.UTF8.GetString(msg.Payload,0,msg.Payload.Length);Console.WriteLine($"Topic:{msg.Topic} Partition:{msg.Partition} Offset:{msg.Offset}{text}");};consumer.Subscribe(new[]{"testtopic"});consumer.Start();Console.WriteLine("Started consumer, press enter to stop consuming");Console.ReadLine();}

More

Documentation

Supported Platforms and .NET Releases