Динамически меняйте настройки конфига кафки в C #

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. Существует ли способ динамического изменения значения num.partitions из C #?

Спасибо MR

Answer 1

Я не вижу num.partitions в этой ссылке

Но, конечно, вы можете прочитать файл свойств или создать таймер для закрытия и повторного создания любого объекта производителя или потребителя.

Но пока работает производитель или потребитель, не существует простого способа перенастроить его свойства.

Не похоже, что библиотека Kafka-Net была обновлена ​​с 2016 года, вы можете использовать клиент confluent-dotnet-kafka.