动态更改c中的配置设置kafka#

qco9c6ql  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(280)

我对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文件中的行数,有没有一种方法可以动态地将num.partitions的值从c#改为value?
谢谢,先生

q3qa4bjr

q3qa4bjr1#

我不明白 num.partitions 在那个环节
但是可以肯定的是,您可以读取一个属性文件,或者创建一个计时器来关闭并重新创建任何生产者或消费者对象。
但是,当生产者或消费者正在运行时,没有直接的方法来重新配置其属性。
看起来不像 Kafka-Net 图书馆从2016年开始更新,你可以使用 confluent-dotnet-kafka 客户。

相关问题