分享

[求助]storm 读取 kafka数据 有关zookeeper的相关设置

ltz 发表于 2016-5-30 19:07:33 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 1 6358
疑问: 在给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());

已有(1)人评论

跳转到指定楼层
einhep 发表于 2016-5-31 11:19:44

回帖奖励 +2 云币

跟上面的路径应该都没有关系
zkroot将作为root来存储你的消费者的偏移。

更多参数,楼主参考这个
https://github.com/apache/storm/tree/master/external/storm-kafka
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条