storm startOffsetTime的问题

查看数: 10056 | 评论数: 3 | 收藏 0
关灯 | 提示:支持键盘翻页<-左 右->
    组图打开中,请稍候......
发布时间: 2016-6-27 18:25

正文摘要:

KafkaConfig有个参数startOffsetTime:默认为kafka.api.OffsetRequest.EarliestTime()开始读,也就是从Kafka中最早的消息开始处理。也可以设成kafka.api.OffsetRequest.LatestOffset,也就是最早的消息开始读。也可以 ...

回复

einhep 发表于 2016-6-28 16:39:24
mjjian0 发表于 2016-6-28 09:12
设置了,设置为true了,storm0.10.0版本的是ignoreZkOffsets(即forceFromStart ),一样的。

楼主是否忽略了其它条件。最开始读取是否也是需要配置的。这个配置是否去掉了
mjjian0 发表于 2016-6-28 09:12:07
qcbb001 发表于 2016-6-27 18:59
楼主这个参数forceFromStart 是否设置了

设置了,设置为true了,storm0.10.0版本的是ignoreZkOffsets(即forceFromStart ),一样的。
qcbb001 发表于 2016-6-27 18:59:33
楼主这个参数forceFromStart 是否设置了


public boolean forceFromStart = false;  // 和startOffsetTime,一起用,默认情况下,为false,一旦startOffsetTime被设置,就要置为true


关闭

推荐上一条 /2 下一条