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

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

我的Kafka套装是

  1. SpoutConfig spoutConf = new SpoutConfig(brokerHosts, topic, zkRoot,clientId);
  2. spoutConf.scheme = new SchemeAsMultiScheme(new StringScheme());
  3. spoutConf.forceFromStart = false;
  4. spoutConf.zkServers=...
  5. spoutConf.zkPort = 2181;
  6. spoutConf.zkHost = ...
  7. spoutConf.zkRoot = zkRoot;

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

暂无答案!

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

相关问题