yellowhealthy 2016-11-18 08:13 采纳率: 0%
浏览 1711

storm kafka startOffsetTime

谁用过storm的kafkaSpout
我想从今天下午1点开始从kafka拉数据

spoutConfig.ignoreZkOffsets=true;
spoutConfig.startOffsetTime=1479445200000l;
这样配置的。结果还是重最开始读取数据，是哪里配置有问题吗？

  • 写回答

2条回答 默认 最新

  • Evankaka 领域专家: 后端开发技术领域 2016-11-19 12:14
    关注

    今天下午1点开始从kafka拉数据。可以换个方案来做，在strom做一个定时发射的spout（,每隔1秒），然后有个bolt专门来接收，判断是否超过一点了。然后就
    可以执行了

    评论

报告相同问题？