Kafka 和 Storm 的动物园管理员

Zookeeper for Kafka and Storm

我开发了一个项目,它从 Kafka 读取消息并在 Storm 中处理它。但是,除了将配置设置为 port:2181 之外,我没有对 zookeeper 做任何事情。在我的项目或 docker yaml 文件中是否有任何关于 Zookeeper 的实现?也许应该是 运行 作为 ProcessBuilder

Kafka进程需要配置Zookeeper。在 server.properties

Storm 还需要 storm.yaml

中的 Zookeeper

Kafka客户端以上,0.9不需要Zookeeper配置。 Storm 拓扑中的任何代码都不需要在没有充分理由的情况下显式使用 Zookeeper。

如果您为这些服务中的每一个使用 Docker,您将需要 link 容器并设置一些环境变量