Toggle navigation
首页
社区
公告
教程
下载
分享
问答
云平台
登 录
注册
flink 消费 kafka,保证数据不丢失且只消费一次语义,也要像 sparkstreaming 一样手动管理 offset 吗?
问答
⋅
ling775000
⋅ 于
2019-11-14 23:16:06
⋅ 最后回复由
青牛
于
2019-11-15 15:50:56
⋅ 4838 阅读
还是flink自己可以有办法处理
×
添加附言
附加内容, 使用此功能的话, 会给所有参加过讨论的人发送提醒.
点赞
成为第一个点赞的人吧
回复数量:
1
青牛
海汼部落创始人,80后程序员一枚,曾就职于金山,喜欢倒腾技术做产品
#1
⋅
2019-11-15 15:50:55
好像严格保证只消费一次的都需要自定义处理,没有现成的办法
暂无评论~~
请注意单词拼写,以及中英文排版,
参考此页
支持 Markdown 格式,
**粗体**
、~~删除线~~、
`单行代码`
, 更多语法请见这里
Markdown 语法
支持表情,可用Emoji的自动补全, 在输入的时候只需要 ":" 就可以自动提示了 :metal: :point_right:
表情列表
:star: :sparkles:
上传图片, 支持拖拽和剪切板黏贴上传, 格式限制 - jpg, png, gif,
教程
发布框支持本地存储功能,会在内容变更时保存,「提交」按钮点击时清空
登 录
注册
Ctrl+Enter
flink 消费 kafka,保证数据不丢失且只消费一次语义,也要像 sparkstreaming 一样手动管理 offset 吗? - 海汼部落 #大数据# @海汼部落
新 建 话 题
作者:ling775000
ling775000 的其他话题
spark 底层是 rdd,flink 底层是怎样的数据结构来维护运算?
flink 消费 kafka,保证数据不丢失且只消费一次语义,也要像 sparkstreaming 一样手动管理 offset 吗?
请问 flume client 是一定要有的角色吗?
threadlocal 和线程局部变量区别是什么?
请问 Linux 里全选的快捷键是什么呢?
请问如何去理解 MPP 架构呢?
请问 BI 开发工程师是做什么的?
毕业两年,在深圳做大数据开发能拿多少呢?
分类下其他主题
镜像空间足够,但不能替换已有镜像?
hadoop 用户不存在?
现在问不了问题?
请问 hadoop 组件中的 hadoop 是安装在 /opt 下还是 /usr/local 下?
HDFS 动态增加节点每次都要重启实验才行是为什么?
MR 任务将数据写入 ORC 文件中,数据采用竖杠(|)进行分割,这个数据分割怎么设置??希望大牛解答谢谢!!
为什么 hive 初始化 MySQL 出错?
为什么安装 datanode 出错?
随机推荐话题
公开课回放
[公告] 海汼部落新人必看帖
[公告] 海汼部落云平台使用教程
[公告] 海汼部落云平台如何保存实操进度(镜像功能)
[公告] 海汼部落云平台资源价格
QQ群1:551936262
关注海汼部落技术社区