AI 助理
备案控制台
开发者社区 问答 正文

blink上支持 datahub从特定offset上开始消费这个特性很赞，对于补数据重跑的场景很合适。

转自钉钉群21789141：blink上支持 datahub从特定offset上开始消费这个特性很赞，对于补数据重跑的场景很合适。

展开
收起
赵慧@ApacheFlink中文社区 2018-10-18 13:26:46 3593 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

2 条回答
写回答
取消 提交回答
  • t3214337-27933

    大佬好，请问flink datastream上消费datahub 怎么配置偏移呀~~

    2020-04-11 15:33:53
    赞同 展开评论
  • 赵慧@ApacheFlink中文社区

    都是这么做的，可能你接触spark稍微早一点

    2019-07-17 23:09:11
    赞同 展开评论
问答分类：
流计算 数据总线 DataHub
问答标签：
数据总线 DataHub数据 blink数据总线 DataHub 数据总线 DataHub blink 数据总线 DataHub场景
问答地址：
开发者社区 > 大数据 > 问答
相关问答
数据传输服务DTS的是否可以用flink消费datahub中的数据写到adb中
98
1
0
使用dataworks的实时同步能增量同步数据吗？从mysql实时同步到datahub
146
2
0
DataWorks中kafka数据如何导入datahub？
315
1
0
两个ASCM控制台，其中一个控制台的Blink消费另一个控制台的DataHub数据，请问可以实现吗？
419
2
0
flink-sql1.3数据从datahub摄入时间与sink hologres的时间怎么获取？
239
4
0
DataWorks有没有办法同步datahub数据时，结束时间设置为任务实际运行开始时间？
97
1
0
DataWorks中从datahub消费数据进odps的方法是什么？
176
1
0
武老师我有个技术问题请教。我的需求是读取opc ua数据，然后写入datahub，请问该如何快速实现
68
1
0
datahub，源端在传数据的时候，报错OGG-15051 Java or JNI
136
0
0
Flink在重跑的期间 datahub的数据持续导入 那增量的数据 是追加到最新保存点的后面么？
63
1
0