服务器 Gind.cn
  1. 服务器 Gind.cn
  3. 与Zookeeper 3.5兼容的Kafkafunction“重新平衡客户端连接”
Intereting Posts
试图安装pecl Solr扩展，但它需要curl 告诉Apache将LF转换为CRLF文本/纯文本 缺lessmod_access_compat.so – 如何编译 ASA5505上的VPN数据包捕获 Nginx：所有本地IP地址redirect到Nginx LVM调整/ home和/ 如何在Exim中延迟对SMTPvalidation失败的回答？ 在Azure中的静态路由 如何使用nginx和proxy_pass为每个创build子域 多个服务器angular色的最佳开发设置？ 硬件：在硬盘驱动器访问之前延迟和明确的“点击” 通过iSCSI SAN在线增加ZFS池的空间 DNS可以为域做故障切换吗？ 睡眠/暂停和WOL在FreeNAS上 为什么SMTP客户端会发送RSET（重置）命令？

与Zookeeper 3.5兼容的Kafkafunction“重新平衡客户端连接”

在这个文档中，Zookeeper 3.5描述了https://zookeeper.apache.org/doc/trunk/zookeeperReconfig.htmldynamicconfigurationfunction。

这个文件有两个要点：

  1. 当更改一个Zookeeper实例的dynamicconfiguration时，该集合中的所有Zookeeper实例自动更新其configuration。
  2. Zookeeper合奏的客户端可以在dynamicconfiguration更新时重新平衡他们的连接，只要他们在Zookeeper中订阅/zookeeper/config ，或者调用getConfig ，并通过调用updateServerList更新他们自己的Zookeeper服务器列表

这一切似乎真的很有希望，因为目前（Kafka 2.12和Zookeeper 3.4.9），Zookeeper和Kafkaconfiguration都是静态的，当需要replaceZookeeper节点时，需要在每个Zookeeper实例上进行configuration更改合奏和每个卡夫卡经纪人，所有参与者需要重新启动重新加载configuration。

我的问题是，只要你使用Zookeeper 3.5并且是新的dynamic重新configuration，是否有一个兼容的Kafka版本，当Zookeeper集成被重新configuration时它将更新它自己的zookeeper.connectconfiguration？