御坂卡夫卡
用于 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 (() =>
{
v
2021-07-07 12:03:17
78KB
C#
1