正在尝试创建confluence.kafka库

Question

我正试图为控制台应用程序创建一个Kafka层。

我安装了Confluent Kafka NuGet包。

在这个代码

private readonly Producer<Null, string> _producer;
private Consumer<Null, string> _consumer;

我有错误

无法在此处访问内部类"Producer"(class(汇流。卡夫卡。制作人<Null，字符串>具有序列化能力的高级生产者。

如何解决此问题？

Answer 1

在新版Confluence Kafka包中，Producer和Consumer是私有类。您必须使用ProducerBuilder和ConsumerBuilder来创建它们。

_producerConfig = new ProducerConfig 
{
BootstrapServers = host
};
_producer = new ProducerBuilder<Null, string>(_producerConfig).Build();
_consumerConfig = new ConsumerConfig
{
GroupId = "custom-group",
BootstrapServers = host
};
_consumer = new ConsumerBuilder<Null, string>(_consumerConfig).Build();