我要实现一个由 3 台机器组成的 kafka 集群，一台用于 zookeeper，另外 2 台作为代理。我有大约 6 台消费者机器和大约 100 台生产者。

现在，如果其中一个代理失败，由于复制功能，可以避免数据丢失。但是如果zo​​okeeper出现故障，同一台机器无法启动怎么办？我有几个问题:

1. 我注意到，即使在 zookeeper 失败后，生产者仍继续在指定代理中推送消息。但消费者再也无法取回它们。因为消费者未注册。那么在这种情况下，数据会永久丢失吗？
2. 如何在运行时更改代理配置中的 zookeeper ip？是否必须关闭它们才能更改 zookeeper ip？
3. 即使之前以某种方式将新的 zookeeper 机器带入集群，之前的数据是否会丢失？

最佳答案

只运行 Zookeeper 的一个实例是不能容错的，行为无法预测。根据HBase reference ，您应该设置一个至少包含 3 台服务器的集成。

查看官方文档页面:Zookeeper clustered setup .

https://stackoverflow.com/questions/33346938/