当主题分区超过1时,storm kafkaspout无法读取偏移量

wvt8vs2t  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(207)

我的Kafka套装是

SpoutConfig spoutConf = new SpoutConfig(brokerHosts, topic, zkRoot,clientId);
    spoutConf.scheme = new SchemeAsMultiScheme(new StringScheme());
    spoutConf.forceFromStart = false;
    spoutConf.zkServers=...
    spoutConf.zkPort = 2181;
    spoutConf.zkHost = ...
    spoutConf.zkRoot = zkRoot;

就像kafka storm中未能将偏移量数据写入zookeeper一样,但是我发现,当我的主题分区大于1时,我的kafkaspout无法从zookeeper读取偏移量,并且zookeeper中没有设置。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题