我开发了一个项目，读取Kafka的信息，并在Storm中处理它。但是，除了将配置设置为port:2181. 在我的项目或docker yaml文件中是否有关于zookeeper的实现？也许它应该作为processbuilder运行
laik7k3q1#
Kafka进程需要配置zookeeper。在 server.properties 风暴也需要放大 storm.yaml kafka客户端0.9以上不需要zookeeper配置。storm拓扑中的任何代码都不需要在没有充分理由的情况下显式地使用zookeeper。如果要为这些服务中的每一个使用docker，则需要链接容器并设置一些环境变量
server.properties
storm.yaml
1条答案
按热度按时间laik7k3q1#
Kafka进程需要配置zookeeper。在
server.properties风暴也需要放大storm.yamlkafka客户端0.9以上不需要zookeeper配置。storm拓扑中的任何代码都不需要在没有充分理由的情况下显式地使用zookeeper。如果要为这些服务中的每一个使用docker，则需要链接容器并设置一些环境变量