分享

storm重复读取kafka数据报错

ld512870 发表于 2016-4-25 09:35:19 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 2 14795
2016-04-25T09:22:25.363+0800 s.k.PartitionManager [WARN] Using new offset: 13228628
2016-04-25T09:22:25.364+0800 s.k.KafkaUtils [WARN] Got fetch request with offset out of range: [8345304]; retrying with default start offset time from configuration. configured start offset time: [-1]
2016-04-25T09:22:25.364+0800 s.k.PartitionManager [WARN] Using new offset: 13228628
2016-04-25T09:22:25.366+0800 s.k.KafkaUtils [WARN] Got fetch request with offset out of range: [8345304]; retrying with default start offset time from configuration. configured start offset time: [-1]
2016-04-25T09:22:25.366+0800 s.k.PartitionManager [WARN] Using new offset: 13228628
2016-04-25T09:22:25.368+0800 s.k.KafkaUtils [WARN] Got fetch request with offset out of range: [8345304]; retrying with default start offset time from configuration. configured start offset time: [-1]
2016-04-25T09:22:25.368+0800 s.k.PartitionManager [WARN] Using new offset: 13228628
2016-04-25T09:22:25.370+0800 s.k.KafkaUtils [WARN] Got fetch request with offset out of range: [8345304]; retrying with default start offset time from configuration. configured start offset time: [-1]
2016-04-25T09:22:25.370+0800 s.k.PartitionManager [WARN] Using new offset: 13228629
2016-04-25T09:22:25.372+0800 s.k.KafkaUtils [WARN] Got fetch request with offset out of range: [8345304]; retrying with default start offset time from configuration. configured start offset time: [-1]

今天Storm日志中出现大量这种错误,求大神给个解决方案啊。

已有(2)人评论

跳转到指定楼层
s060403072 发表于 2016-4-25 10:32:48
首先看下版本:
1.0.9.2-incubating, 0.9.3, 0.10.0, 0.9.4, 0.9.5存在这么个bug,0.9.6已经解决
2.多个topic不能共用一个zookeeper根目录data
    SpoutConfig spoutConfig = new SpoutConfig(zkHosts, topic, "/data","logProcess");
回复

使用道具 举报

ld512870 发表于 2016-4-25 14:15:04
s060403072 发表于 2016-4-25 10:32
首先看下版本:
1.0.9.2-incubating, 0.9.3, 0.10.0, 0.9.4, 0.9.5存在这么个bug,0.9.6已经解决
2.多个t ...

我勒个去。。。。我就在用0.9.5的kafka。。。。。。
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条