我的 KafkaSpout 套装是
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 中没有设置。