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