疑问: 在给SpoutConfig 传递第三个参数zkroot时,这个zkroot的路径是怎么确定的,我在storm配置文件中配置zk时,只配置了
[mw_shl_code=java,true] storm.zookeeper.servers:
- "hadoop"
[/mw_shl_code]
在kafka中配置的 server.properties配置的zk
[mw_shl_code=applescript,true]zookeeper.connect=localhost:2181
# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000
[/mw_shl_code]
我去zk根目录下看到的目录有:
[mw_shl_code=applescript,true][zk: hadoop:2181(CONNECTED) 21] ls /
[hbase, zookeeper, admin, consumers, hdfs, config, controller, storm, brokers, controller_epoch]
[zk: hadoop:2181(CONNECTED) 22] [/mw_shl_code]
请问,SpoutConfig方法中的第三个参数是指的哪个路径下的信息,谢谢!
SpoutConfig spoutConfig=new SpoutConfig(hosts,topicName,?????, UUID.randomUUID().toString());
|