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

返回频道云消息队列 Kafka 版offset

问答 2021-12-08 来自：开发者社区

kafka中实现低级API如何使用代码来设置分区和offset？

问答 2021-12-08 来自：开发者社区

Flink SQL kafka connector有办法获取到partition、offset信息嘛

如题，需要获取到kafka的partition、offset进行处理 *来自志愿者整理的flink邮件归档

问答 2021-12-08 来自：开发者社区

flinksql 消费kafka offset问题

flink消费kafka 只能使用checkpoint去维护offset吗我这边使用'scan.startup.mode' = 'group-offsets' 如果中间报错了或者停止任务，但是我下游sink还没有完成，下次启动直接跳过这个报错的数据，会丢数据，谢谢回复*来自志愿者整理的flink邮件归档

问答 2021-12-07 来自：开发者社区

大家晚上好，我们这里用flink消费kafka，往mysql写。topic有9个分区，flink任务并行度是3。任务却一直报这个错：2019-08-21 19:33:07,058 WARN org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase - Async Kafka commit failed. org.apac....

问答 2021-12-07 来自：开发者社区

flink不清理state，从checkpoint恢复任务能重置kafka的offset讨论

Hi everyone：如题，我遇到有些数据我不应该漏了想回溯部分数据，这个时候我就需要清理state，来重置kafka的offset重新跑，可不可以保留flink任务state，从checkpoint恢复任务的时候重置kafka的offset，并从kafka那个时间段开始消费，而不需要清掉state重新跑数据。*来自志愿者整理的flink邮件归档

问答 2021-12-07 来自：开发者社区

如果checkpoint时间过长，offset未提交到kafka重启之后的重复消费如何保证呢？

问答 2021-12-07 来自：开发者社区

Flink kafka Consumer的commit offset方式有什么？

共有73条

< 1 ... 3 4 5 6 ... 8 >

跳转至： GO

更新时间 2024-10-17 18:55:38

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

云消息队列 Kafka 版更多offset相关

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

产品推荐

热门帮助文档

云消息队列

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

+关注

kafka中实现低级API如何使用代码来设置分区和offset？

kafka中consumer默认将offset保存在哪里？

kafka中的offset维护的步骤是什么？

kafka中offset是如何维护的？

Flink SQL kafka connector有办法获取到partition、offset信息嘛

flinksql 消费kafka offset问题

flink频繁报向kafka提交offset失败的错误

flink不清理state，从checkpoint恢复任务能重置kafka的offset讨论

如果checkpoint时间过长，offset未提交到kafka重启之后的重复消费如何保证呢？

Flink kafka Consumer的commit offset方式有什么？

云消息队列 Kafka 版更多offset相关

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

产品推荐