Storm zkRoot ist nicht erstellt

Question

Ich wollte die Storm-Kafka-Topologie erstellen, aber die Tülle lesen Sie die Daten von Kafka wiederholbar, und ich fand, dass die zkRoot wurde nicht erstellt. Kennt jemand den Grund?

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

Versuchen Sie, die "/" von zkroot

String zkRoot = "stormffbkafka";

Dank zu entfernen.