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

fink新增计算逻辑时kafka从头开始追平消费记录是怎么回事？

latest 不是最后消费的位置吗？ 另外我一直不明白的是，如果我不新增新的算子，从savepoint启动是没有问题的。不会从头开始消费，之后新增算子后才会出现这个情况。*来自志愿者整理的FLINK邮件归档

展开
收起
玛丽莲梦嘉 2021-12-03 18:38:03 1618 分享 版权

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

1 条回答
写回答
取消 提交回答
  • CCCC

    offset 是最后消费的位置，latest 针对的是kafka topic，对应是的 latest 的消息。 savepoint 内部就是 从offset开始读的。*来自志愿者整理的FLINK邮件归档

    2021-12-03 19:00:43
    赞同 展开评论
问答分类：
消息中间件 Kafka 流计算 云消息队列 Kafka 版 实时计算 Flink版
问答标签：
计算云消息队列 Kafka 版 云消息队列 Kafka 版消费记录 云消息队列 Kafka 版消费
问答地址：
开发者社区 > 微服务 > 问答
相关问答
用flinkcdc读取rds的数据，然后再用flink计算指标，中间需要用kafka之类的中间件吗？
144
1
0
Flink 处理 Kafka的数据，需要 join 一个基础表来计算，会实时的体现在 计算结果里吗？
87
1
0
flink sql作业中，计算结果可以动态写入kafka不同主题吗？
65
1
0
Flink CDC有个消费kafka的问题很困惑，一秒钟16000条数据，flink就消费，没计算？
353
3
0
ApacheFLink任务实时消费Kafka窗口的计算要改成maxcompute要怎么实现呢？
131
6
0
flinksql消费kafka，没有消费记录的分区在sp的时候是不是不保存偏移量？
84
1
0
一个Flink SQl的job中，消费同一个kafka，使用滚动窗口计算每小时的统计，使用渐进式窗？
145
1
0
请问Flink CDC中计算结果需要同时写到kafka ,redis ,数据库表 只用一个自定义?
149
0
0
请教个问题flink消费kafka特别慢5.条每秒，如何优化
1698
1
0
这种数据，怎么设置kafka source，才能让flink 继续消费？
672
0
0