御坂卡夫卡用于Apache Kafka的高性能C#客户端。该客户端不支持所有可能的功能,而是为长期运行的生产者/消费者提供简约轻量级的Kafka客户端。该代码基于James Roland的KafkaNet实现,经过大幅精简和优化。构建状态:NuGet包。例子制作人:
var options = new KafkaOptions(new Uri(\"http://kafka1:9092\"), new Uri(\"http://kafka2:9092\")) {
Log = new ConsoleLog()
};
var router = new BrokerRouter(options);
var client = new Producer(router);
Task.Run(() => {
// 示例代码逻辑
});
暂无评论