我的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中没有设置。
暂无答案!
目前还没有任何答案,快来回答吧!