В этом документе https://zookeeper.apache.org/doc/trunk/zookeeperReconfig.html описана функциональность динамической конфигурации для Zookeeper 3.5.
В этом документе есть 2 важных момента:
/ zookeeper / config
в Zookeeper или, в качестве альтернативы, вызывают getConfig
и обновляют свои собственный список серверов Zookeeper, вызвав updateServerList
. Все это кажется действительно многообещающим, потому что на данный момент (Kafka 2.12 и Zookeeper 3.4.9) конфигурации Zookeeper и Kafka статичны, и когда узел Zookeeper должен получить При замене конфигурации необходимо внести изменения в каждый экземпляр Zookeeper в ансамбле и на каждом брокере Kafka, а также перезапустить всех участников для перезагрузки конфигураций.
У меня вопрос: при условии, что вы используете Zookeeper 3.5 и его новую динамическую реконфигурацию, есть ли версия Kafka, совместимая с этим, который обновит свою собственную конфигурацию zookeeper.connect, когда ансамбль Zookeeper будет перенастроен?
Kafka 2.0 обновляет zk до 3.4.12 https://issues.apache.org/jira/browse/KAFKA-6390 .
И это было выпущено совсем недавно. Так что я думаю, нам нужно подождать еще немного?