卡夫卡集群的优雅关闭

Question

我有一个由4个经纪人组成的卡夫卡集群，由5个动物园管理员管理。

5个动物园管理员的IP将同时改变，所以我需要停止所有卡夫卡节点在它之前，然后(在动物园管理员IPs改变之后)重新启动它们。

从Kafka文档中我知道，我可以添加参数：

controlled.shutdown.enable=true

然后将这个命令发送给kafka broker：

bin/kafka-server-stop.sh

但它与一个节点重新启动(滚动重新启动)相关。

1. ，我能让完全重新启动更优雅，然后仅仅通过停止所有的卡夫卡服务在同一时间？我希望卡夫卡在完全重启后尽快恢复。也许我可以向卡夫卡发出一个信号，表明整个集群将被关闭？
2. ，如果我停下来，像这样启动卡夫卡，会不会有丢失数据的风险？(动物园管理员只是立即改变他们的IP，动物园管理员的数据没有改变)。

卡夫卡版本：2.4.0

动物园管理员版本：3.4.13

Answer 1

为了优雅地停止集群，首先停止向其生成新事件并停止所有使用者。这将确保您将没有数据损失在完全关闭。

一旦集群空闲，您就可以停止每个节点，直到最后一个节点停止为止。然后更改您的ZK地址-> Update配置以处理新的ZK地址并启动Kafka集群，您可以一个接一个地或一次完成。

controlled.shutdown.enable确保在节点关闭期间数据不会丢失，数据将被写入磁盘。