尝试创建 confluence.kafka 库

Question

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

我安装了 Confluent Kafka NuGet 包。

在这段代码中

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

我有错误

无法在此处访问内部类“Producer” (class) Confluent.Kafka.Producer 具有序列化能力的高级生产者。

我该如何解决这个问题？

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();