云消息队列 Kafka 版checkpoint 的相关内容

问答 2023-08-29 来自：开发者社区

这个flink问题怎么解决？

这个flink问题怎么解决？ sql 消费kafka，开启了checkpoint。topic每个分区都是有数据，现在监控发现，flink作业在提交offset的时候，消费一段时间后，有1个partition的数据offset不提交了，但是这个partition一直有数据。

问答 2023-08-28 来自：开发者社区

Flink CDC 1.15.2 开启checkpoint 消费kafka ，过一段时间后，不提交？

Flink CDC 1.15.2 开启checkpoint 消费kafka ，过一段时间后，不提交offset，日志只有warn:Commit offsets failed with retriable exception. You should retry committing offsetskafka ,大家有遇到嘛？ kafka一直有数据

问答 2023-08-23 来自：开发者社区

请教大家一个flink sql 消费kafka，开启了checkpoint。topic每个分区都是有

请教大家一个flink sql 消费kafka，开启了checkpoint。topic每个分区都是有数据，现在监控发现，flink作业在提交offset的时候，消费一段时间后，有1个partition的数据offset不提交了，但是这个partition一直有数据

问答 2023-07-13 来自：开发者社区

flink connector kafka 一直重复消费数据怎么回事呢？开启了checkpoint

问答 2023-06-12 来自：开发者社区

近期的消费速度是如何获取的？kafka的积压消费量受flink checkpoint周期长短影响

问答 2023-03-07 来自：开发者社区

checkpoint保存kafka offset吗？

checkpoint保存kafka offset吗？我模式设置的是从最新开始消费，当任务从checkpoint重启时，感觉没从上次offset开始消费，任务停掉后到重启中间的数据没消费到。

问答 2023-02-06 来自：开发者社区

Flink CDC要是下游是kafka的话，是不是直接使用checkpoint？

Flink CDC要是下游是kafka的话，是不是直接使用checkpoint，还需要额外的存储介质来保存checkpoint信息吗？

问答 2023-01-08 来自：开发者社区

有没有知道cdc 从Oracle到kafka，checkpoint 导致source背压怎么解决吗？

有没有大佬知道cdc 从Oracle到kafka，checkpoint 导致source背压怎么解决吗，cdc的source并行度只能设置为1。

问答 2022-12-27 来自：开发者社区

4个slot消费kafka数据，但是有两个slot checkpoint一直不成功，有可能是什么原因

问答 2022-11-22 来自：开发者社区

请问下，sink还没有成功，执行checkpoint会把这条数据的offset提交到kafka吗？会

请问下，sink还没有成功，执行checkpoint会把这条数据的offset提交到kafka吗？会不会存在还没sink成功，但已经把offset提上去了的情况呢？

共有19条

< 1 2 >

跳转至： GO

更新时间 2023-08-31 21:49:24

本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。

云消息队列 Kafka 版checkpoint相关内容

checkpoint云消息队列 Kafka 版

云消息队列 Kafka 版您可能感兴趣

产品推荐

热门帮助文档

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系，全系产品 Serverless 化。RocketMQ 一站式学习：https://rocketmq.io/

+关注