Kafka, совместимый с функцией Zookeeper 3.5 «Ребалансировка клиентских подключений»

В этом документе https://zookeeper.apache.org/doc/trunk/zookeeperReconfig.html описана функциональность динамической конфигурации для Zookeeper 3.5.

В этом документе есть 2 важных момента:

  1. При изменении динамической конфигурации одного экземпляра Zookeeper все экземпляры Zookeeper в ансамбле автоматически обновляют свои конфигурации.
  2. Клиенты ансамбля Zookeeper могут перебалансировать свои соединения при обновлении динамической конфигурации, при условии, что они подписаны на / 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 будет перенастроен?

4
задан 8 June 2017 в 16:40
1 ответ