Flink消费kafka过一段时间后，不提交offset，日志只有这个为什么？
Flink 1.15.2 开启checkpoint 消费kafka ，过一段时间后，不提交offset，日志只有warn:Commit offsets failed with retriable exception. You should retry committing offsetskafka ...
大家有遇到 flinsql 消费kafka，开了checkping 但是不提交offset的情况吗？
大家有遇到 flinsql 消费kafka，开了checkping 但是不提交offset的情况吗？
Kafka学习---4、消费者（分区消费、分区平衡策略、offset、漏消费和重复消费）(二）
1.3.2 独立消费者案例（订阅分区）1、需求：创建一个独立消费者，消费first主题0号分区的数据2、实现步骤（1）代码编写package org.zhm.consumer; import org.apache.kafka.clients.consumer.ConsumerConfig; impo...
Kafka学习---4、消费者（分区消费、分区平衡策略、offset、漏消费和重复消费）(一）
1、消费者1.1 Kafka消费方式1、pull（拉）模式：consumer采用从broker中主动拉取数据。2、push（推）模式：Kafka没有采用这种方式。因为broker决定消息发生速率，很难适应所有消费者的消费速率。例如推送的速度是50M/s，Consumer1、Consum...
大佬们，Flink对接Kafka结果Kafka的元数据（事务ID，Offset之类）找不到了咋办？!
大佬们，Flink对接Kafka结果Kafka的元数据（事务ID，Offset之类）找不到了咋办？我这是磁盘满了。 Flink 先消费Kafka 再写Kafka ，中间断了两周，然后再从两周前的检查点启动 就起不来了
flink kafka 消费的数据 如果分批数据，那么offset 是连续的吗？
flink kafka 消费的数据 如果分批数据，那么offset 是连续的吗？
checkpoint保存kafka offset吗？
checkpoint保存kafka offset吗？我模式设置的是从最新开始消费，当任务从checkpoint重启时，感觉没从上次offset开始消费，任务停掉后到重启中间的数据没消费到。
实时计算 Flink版这种kafka offset模式应该怎么设置？
kafka的offset有没有保存在checkoutpoint里。比如我一个任务每天上午运行，中午后就关掉，第二天早上在启动，早上启动后从最新的kafka数据开始读。但是如果上午任务失败或者重启啥的从上次offset读。这种kafka offset模式应该怎么设置，设置group-offset应该不...
flink 手动维护kafka offset
flink 自定义管理kafka offset我们都知道flink 程序自行设置指定offset配合checkpint 的方式，来获取便宜量。并且可以通过state和设置事件语义，达到exactly-once.但是仍然有一些场景需要自己手工管理offset.用过spark的同学都知道，sp...
更新时间 2023-08-30 09:48:06
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
社区圈子
