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