storm kafka startOffsetTime

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

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

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除结题
收藏举报

2条回答默认最新

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
Evankaka 博客专家认证 2016-11-19 12:14
关注
今天下午1点开始从kafka拉数据。可以换个方案来做，在strom做一个定时发射的spout（,每隔1秒），然后有个bolt专门来接收，判断是否超过一点了。然后就
可以执行了

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

spark structured steaming与kafka集成offset管理方式 kafka spark
2023-01-31 14:43

回答 2 已采纳 Spark Structured Streaming 集成 Kafka 的 offset 管理方式有如下几种：利用 Spark checkpoint 文件提交 offset 给 Kafka常用的方案
为什么kafka启动总是报错呢？ kafka linux storm
2022-09-01 17:56

回答 2 已采纳似乎是权限问题，你可以看看报错的文件路径权限组看看，使用 ls -l /home/…
kafka拉取不到数据 java kafka 分布式有问必答
2022-02-16 19:32

回答 4 已采纳重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
大数据之kafka
2022-05-01 21:21

qq_37705525的博客 大数据之kafka
zookeeper 设置 Acl 后 kafka 启动失败 kafka zookeeper 分布式
2022-09-26 17:35

回答 1 已采纳网上都有相关文章，例如，你可以参考这篇：https://www.bilibili.com/read/cv11773508里面就有涉及到这两个的安全认证配置。
在win10启动kafka报错 kafka zookeeper
2022-05-15 21:27

回答 1 已采纳删除异常的主题“movie_real_topic”试试.\bin\kafka-topics --delete --topic movie_real_topic --zookeeper localhos
kafka怎么获取之前的offset java linux
2020-04-28 14:06

回答 1 已采纳 kafka消费是可以指定offset的，你手动指定一个不就好了？多个生产者同时发送数据，你是要保证按照发送的顺序一一写到数据库中么？这样子的话可以只给当前topic，设置一个分区就行了不知道我
大数据必知必会之Kafka
2022-08-25 14:26

运维开发故事的博客 Kafka 起初是由 LinkedIn 公司采用 Scala 语言开发的一个多分区、多副本且基于 ZooKeeper 协调的分布式消息系统，现已被捐献给 Apache 基金会。目前 Kafka 已经定位为一个分布式流式处理平台，它以高吞吐、可持久化...
kafka无法正常启动 kafka
2022-11-14 16:38

回答 2 已采纳帮你找了个相似的问题, 你可以看下: https://ask.csdn.net/questions/7763153这篇博客你也可以参考下：搭建kafka环境遇到kafka闪退问题以及解决办法这篇博客也
kafka和storm集成是报错，找不到jar包 jar java kafka
2017-04-10 02:55

回答 2 已采纳我自己解决了，是jar包版本引用错误的问题，必须引用curator-framework-1和curator-client-1的版本的jar包， 2版本以后jar包中的包名是org.org.apach
kafka集成flume flume kafka
2023-03-03 20:36

回答 1 已采纳 “Devil组”引证GPT后的撰写：可能有多种原因导致消费者没有消费到所有追加的内容。以下是一些可能的原因：日志追加速度太快，消费者无法跟上。如果日志追加速度非常快，而消费者无法及时消费所有消息，那
【Kafka】大数据实时框架_kafka
2023-09-11 10:25

花村游戏店老板的博客 大数据实时框架_kafka https://www.orchome.com/kafka/index kafka中文教程文章目录 大数据实时框架_kafka 1. 消息队列的介绍 1.1 常见的消息队列产品 1.2 消息队列的应用场景 1.2.1 异步处理 1.2.2 应用耦合 1.2.3...
kafka可以生产无法消费的问题 java kafka
2022-06-11 10:41

回答 1 已采纳给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
大数据系列七：Storm实时流计算-滑动窗口（Kafka to File）
2020-06-26 17:44

henry.zhu的博客 Storm安装配置没有使用Hadoop，比较简单，网络相关介绍比较多，大概列下。二.安装配置 2.1 tar -zxvf apache-storm-1.0.5.tar.gz 2.2 vi /etc/profile STORM_HOME=/mnt/data/software/storm PATH=PATH:PATH:PATH:...
Flume+Kafka+Storm+Redis 大数据在线实时分析
2019-05-20 20:47

weixin_30877227的博客从构建实时处理系统的角度出发，我们需要做的是，如何让数据在各个不同的集群系统之间打通（从上面的图示中也能很好地说明这一点），即需要做各个系统之前的整合，包括Flume与Kafka的整合，Kafka与Storm的整合。...
没有解决我的问题, 去提问

悬赏问题

¥15 msix packaging tool打包问题
¥28 微信小程序开发页面布局没问题，真机调试的时候页面布局就乱了
¥15 python的qt5界面
¥15 无线电能传输系统MATLAB仿真问题
¥50 如何用脚本实现输入法的热键设置
¥20 我想使用一些网络协议或者部分协议也行，主要想实现类似于traceroute的一定步长内的路由拓扑功能
¥30 深度学习，前后端连接
¥15 孟德尔随机化结果不一致
¥15 apm2.8飞控罗盘bad health，加速度计校准失败
¥15 求解O-S方程的特征值问题给出边界层布拉休斯平行流的中性曲线

storm kafka startOffsetTime

2条回答 默认 最新

悬赏问题

2条回答默认最新