阿里云文档 2024-11-28

如何在控制台管理Consumer的offset

本文为您介绍Consumer在读取消息异常中断后,如何在控制台管理Consumer的offset。

阿里云文档 2023-12-13

通过offset和时间段查询消息

在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时,您可通过消息查询功能查看指定消息的详细内容和相关属性,帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点,可采用按位点查询消息;若不确定消息的位置,但确定消息发送的时间段,可采用按时间查询消息。

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

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

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

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

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

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

问答 2021-01-06 来自:开发者社区

如果 checkpoint offset 未提交到 kafka,此时节点宕机了,重启重复消费如何保证

如果 checkpoint 时间过长,offset 未提交到 kafka,此时节点宕机了,重启之后的重复消费如何保证呢?

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注