Rebus.Kafka

Provides a Apache Kafka transport implementation for Rebus.

Using Rebus.Kafka:

builder.RegisterRebus((configurer, context) => configurer
	.Transport(t => t.UseKafka("localhost:9092", "InputQueueName", "groupName"))
);

See unit tests for details.

Note:

So as to interact with the Apache Kafka requires the unmanaged "librdkafka", you need to install the package "librdkafka.redist -Version 1.0.0-RC7 or newer". If this unmanaged "librdkafka" is not found automatically, you must load it before you can use Rebus.Kafka for the first time as follows:

if (!Library.IsLoaded)
	Confluent.Kafka.Library.Load(pathToLibrd);

---

If you have any recommendations or comments, I will be glad to hear.