c# - 在 C# 中动态更改配置设置 kafka

Question

我对 Apache Kafka 很陌生。我在 C#.NET /Windows 平台上工作。我能够使用 Kafka 的配置设置并使用命令提示符发送和接收消息。

使用https://www.codeguru.com/csharp/.net/producer-and-consumer-for-kafka-in-.net-an-exploration.html 我运行了 c# 程序并能够生成和接收消息。Qn1：我正在尝试读取 json 文件并根据 json 文件中的行数，有没有办法从 C# 动态更改 num.partitions 值的值？

谢谢先生

Answer 1

我没有num.partitions在那个链接中看到

但可以肯定的是，您可以读取一个属性文件，或者制作一个计时器来关闭并重新创建任何生产者或消费者对象。

但是，当生产者或消费者正在运行时，没有直接的方法可以重新配置其属性。

看起来该Kafka-Net库自 2016 年以来没有更新，您可以使用confluent-dotnet-kafka客户端。