现在，我刚刚成功地建立了我的风暴拓扑与单节点在单机上。我使用Kafka普特如下：
String zkHostPort = "localhost:2181";
String topic = "sentences";
String zkRoot = "/kafka-sentence-spout";
String zkSpoutId = "sentence-spout";
ZkHosts zkHosts = new ZkHosts(zkHostPort);
SpoutConfig spoutCfg = new SpoutConfig(zkHosts, topic, zkRoot, zkSpoutId);
KafkaSpout kafkaSpout = new KafkaSpout(spoutCfg);
return kafkaSpout;现在我设置了集群zookeeper（三个节点：server1）。com:2181，服务器2。com:2181. 服务器3。com:2181)簇kafka（三节点）。我想知道我如何才能改变代码风暴拓扑为这个目的。请帮帮我！！
1条答案
按热度按时间mdfafbf11#
请使用以下配置：
注意：这里最常见的问题是逗号后主机之间的空格，主机之间不能有空格。
对的：
服务器1。com:2181，服务器2。com:2181，服务器3。com:2181
错误：
服务器1。com:2181，服务器2。com:2181，服务器3。com:2181