您的位置:首页 > 其它

storm-kafka spout获取数据的异常解决办法

2015-01-09 13:50 357 查看
20391 [Thread-8-kfkaSpout] WARN  storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140885176]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532601]
21680 [Thread-8-kfkaSpout] WARN  storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140889217]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532613]
22749 [Thread-8-kfkaSpout] WARN  storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140890119]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532311]
23771 [Thread-8-kfkaSpout] WARN  storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140884842]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532819]
24681 [Thread-8-kfkaSpout] WARN  storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140772081]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532980]
25611 [Thread-8-kfkaSpout] WARN  storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140885176]; retrying with default start offset


多个topic不能共用一个zookeeper根目录data

SpoutConfig spoutConfig = new SpoutConfig(zkHosts, topic, "/data","logProcess");
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐