var options = new KafkaOptions(new Uri("http://localhost:9092"));

var router = new BrokerRouter(options);

using (Producer client = new Producer(router))

{

client.SendMessageAsync("test_topic", new[] { new Message("hello world")}).Wait();

}

var options = new KafkaOptions(new Uri("http://localhost:9092"));

var router = new BrokerRouter(options);

using (var consumer = new Consumer(new ConsumerOptions("test_topic", router)))

{

//Consume returns a blocking IEnumerable (ie: never ending stream)

foreach (var messageinconsumer.Consume())

{

Console.WriteLine("Response: P{0},O{1} : {2}",

message.Meta.PartitionId, message.Meta.Offset, message.Value);

}

}