ストームzkRootが作成されていない

Question

私はstorm-kafkaトポロジーを作成したいと思いましたが、スパウトがkafkaからデータを繰り返し読み込みましたが、zkRootが作成されていないことがわかりました。誰もその理由を知っていますか？

String brokerZkStr = "192.168.2.125:2181"; 
String topic = "topic_kafka"; 
String zkRoot = "/stormffbkafka"; 
String id = "kafka-word"; 
TopologyBuilder builder = new TopologyBuilder(); 
BrokerHosts hosts = new ZkHosts(brokerZkStr); 
SpoutConfig spoutConfig = new SpoutConfig(hosts, topic, zkRoot, id); 

spoutConfig.scheme = new SchemeAsMultiScheme(new StringScheme()); 
spoutConfig.zkServers=new ArrayList<String>(Arrays.asList("192.168.2.125")); 
spoutConfig.zkPort = 2181; 
KafkaSpout kafkaSpout = new KafkaSpout(spoutConfig); 

Answer 1

zkroot

String zkRoot = "stormffbkafka";

からの感謝を "/" を削除してください。