在Storm Topology上配置群集ZK_HOST

Question

现在我刚刚在单机上成功地设置了我的风暴拓扑。我使用KafkaSpout如下：

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;

现在我设置了集群动物园管理员（三个节点：server1.com.2181，server2.com.2181。server3.com.2181）和集群kafka（三节点）。我想知道如何为此目的更改Storm Topology上的代码。请帮帮我！！

Answer 1

请使用以下配置：

String zkHostPort = "server1.com:2181,server2.com:2181,server3.com: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;

注意：这里最常见的问题是主机之间逗号后的空格，主机之间不能有空格。

正确：

server1.com.2181、server2.com.2181和server3.com.2181

错误：

server1.com.2181、server2.com.2181和server3.com.2181