阿里云文档 2024-11-28

如何在控制台管理Consumer的offset

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

阿里云文档 2023-12-13

通过offset和时间段查询消息

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

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

大佬们,Flink对接Kafka结果Kafka的元数据(事务ID,Offset之类)找不到了咋办?!

大佬们,Flink对接Kafka结果Kafka的元数据(事务ID,Offset之类)找不到了咋办?我这是磁盘满了。 Flink 先消费Kafka 再写Kafka ,中间断了两周,然后再从两周前的检查点启动 就起不来了

文章 2023-01-11 来自:开发者社区

SpringBoot-Kafka(生产者事务、手动提交offset、定时消费、消息转发、过滤消息内容、自定义分区器、提高吞吐量)

pom.xml<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <version>2.6.0...

SpringBoot-Kafka(生产者事务、手动提交offset、定时消费、消息转发、过滤消息内容、自定义分区器、提高吞吐量)

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

产品推荐

云消息队列

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

+关注