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 容器并设置一些环境变量
我开发了一个项目,它从 Kafka 读取消息并在 Storm 中处理它。但是,除了将配置设置为 port:2181 之外,我没有对 zookeeper 做任何事情。在我的项目或 docker yaml 文件中是否有任何关于 Zookeeper 的实现?也许应该是 运行 作为 ProcessBuilder
Kafka进程需要配置Zookeeper。在 server.properties
Storm 还需要 storm.yaml
Kafka客户端以上,0.9不需要Zookeeper配置。 Storm 拓扑中的任何代码都不需要在没有充分理由的情况下显式使用 Zookeeper。
如果您为这些服务中的每一个使用 Docker,您将需要 link 容器并设置一些环境变量