Storm zkRoot не создан

Question

Я хотел создать топологию storm-kafka, но носик читал данные с kafka repeatable, и я обнаружил, что 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";

Спасибо.