我正在尝试Kafkac#客户端库。首先,我在confluent kafka dotnet中构建了一个基本的生产者和消费者应用程序,老实说,它满足了我的需求,不过,我想尝试一下kafka net库。
但我找不到一种通过组id来消费值的方法,比如合流kafka dotnet。
var conf = new ConsumerConfig
{
GroupId = "test-consumer-group",
BootstrapServers = "localhost:9092",
AutoOffsetReset = AutoOffsetResetType.Latest
};
在Kafka网络中,有没有办法给消费者分配一个组id?
谢谢。
暂无答案!
目前还没有任何答案,快来回答吧!