rocketmq消费进度
社区干货
如何解决使用RocketMQ的消息轨迹信息无法查看问题
# 问题描述RocketMQ 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下:1. 客户端 SDK 使用的版本不对, 需要使用 SDK 版本为 4.8.0, 4.7 和 4.9 的版本均会导致前端页... 消费轨迹功能,enableMsgTrace 需要设置为 true,* 生产者开启消息轨迹:```javaAclClientRPCHook aclHook = new AclClientRPCHook(new SessionCredentials(ACL_ACCESS_KEY,ACL_SECRET_KEY));DefaultMQProducer ...
RocketMQ 存储机制浅析
RocketMQ 是一个典型的发布订阅系统,通过 Broker 节点中转和持久化数据、解耦上下游。Broker 是真实存储数据的节点,由多个水平部署但不一定完全对等的副本组构成,单个副本组的不同节点的数据会达到最终一致。Rocke... │ ├── consumerFilter.json // 消费者的过滤器 │ ├── consumerFilter.json.bak │ ├── consumerOffset.json // offsetTable记录消费进度偏移量 │ ├── co...
使用golang调用RocketMQ SDK
# 前言本文档介绍使用go语言调用火山引擎RocketMQ SDK。# 关于实验- 预计部署时间:30分钟- 级别:初级- 相关产品:中间件-RocketMQ- 受众: 通用# 实验说明## 第一步、创建RocketMQ实例在控制台创建RocketMQ... //此处填写控制台RocketMQ实例概览中的TCP内网接入点,目前不支持公网接入,示例http://MQ_INST_50392uo8m9em_xxxxx.rocketmq.ivolces.com:9876 producer.WithRetry(2), producer.WithCredentials(primitive.Cre...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。
特惠活动
rocketmq消费进度-优选内容
rocketmq消费进度-相关内容
如何解决使用RocketMQ的消息轨迹信息无法查看问题
# 问题描述RocketMQ 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下:1. 客户端 SDK 使用的版本不对, 需要使用 SDK 版本为 4.8.0, 4.7 和 4.9 的版本均会导致前端页... 消费轨迹功能,enableMsgTrace 需要设置为 true,* 生产者开启消息轨迹:```javaAclClientRPCHook aclHook = new AclClientRPCHook(new SessionCredentials(ACL_ACCESS_KEY,ACL_SECRET_KEY));DefaultMQProducer ...
死信消息概述
在 RocketMQ 中,死信队列用于处理无法被正常消费的消息,即死信消息。 背景信息如果一条消息消费失败,消息队列 RocketMQ版会自动重试消费,达到最大重试次数后,如果仍旧消费失败,说明消费者在正常情况下无法正确地消费该消息,这种消息被称为死信消息(Dead-Letter Message)。消息队列 RocketMQ版不会立刻丢弃消息,而是将死信消息发送至该消费者对应的特殊队列中,这种存储死信消息的特殊队列称为死信队列(Dead-Letter Queue)。在消息...
重置消费位点
在清除堆积消息、离线数据处理等场景下,需要消费过去某个时段的消息,或清除所有堆积消息,可以对消费位点进行重置操作。消息队列 RocketMQ版控制台支持重置消费位点,改变订阅者当前的消费位置,您可以通过重置消费位点功能直接从最新 Offset 位点或某个指定时间点来消费消息。 背景信息消息队列 RocketMQ版支持重置 Group 订阅的某一 Topic 或所有 Topic 的消费位点,支持的重置方式包括以下两种。 从最新位点开始消费:该 Group 在消...
通过 RocketMQ 消费 Canal Proto 格式的订阅数据
数据库传输服务 DTS 的数据订阅服务支持使用 RocketMQ 客户端消费 Canal Proto 格式的订阅数据。本文以订阅云数据库 MySQL 版实例为例,介绍如何使用 Go 和 Java 语言消费 Canal Proto 格式的数据。 前提条件已注册... import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.*; import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocke...
步骤三:生产消费普通消息
介绍消息队列 RocketMQ版收发普通消息的基本步骤。 注意事项在使用 Java SDK 接入火山引擎消息队列 RocketMQ版收发消息时,需要配置相应的消息生产或消费参数。您可以参考参数说明,了解相关的参数信息。消息队列 Ro... import org.apache.rocketmq.acl.common.AclClientRPCHook;import org.apache.rocketmq.acl.common.SessionCredentials;import org.apache.rocketmq.client.exception.MQClientException;import org.apache.rocket...
RocketMQ 客户端使用建议
本文档介绍 RocketMQ 客户端的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 日志配置RocketMQ 的日志一般是单独配置的,业务日志独立管理。日志默认保存在 ${user.home}/logs/rocketmqlogs 目录的 10 个文件中,每个文件大小为 1G,日志文件名为 rocketmq_client.log。有些业务的用户目录的磁盘空间不大,很容易造成磁盘空间不足。您可以通过设置系统变量的方式配置 ...
欠费或到期说明
本文介绍消息队列 RocketMQ版实例按量计费和包年包月的欠费说明。 欠费说明欠费后,请您及时充值并结清欠费账单,否则您将无法使用消息队列 RocketMQ版资源。超过欠费保留期,资源会被强制回收,相关数据将无法恢复。无论您的实例资源是否冻结或释放,已出具账单的费用,您应据实结算。 按量计费实例对于按量计费的实例,平台会按小时出具账单,且出具账单后实时结算扣款,如果您账户中的可用额度(含账户余额和代金券)小于待结算的账单,会...
通过 RocketMQ 消费火山引擎 Proto 格式的订阅数据
数据库传输服务 DTS 的数据订阅服务支持使用 RocketMQ 客户端消费火山引擎 Proto 格式的订阅数据。本文以订阅云数据库 MySQL 版实例为例,介绍如何使用 Go 和 Java 语言消费 Canal 格式的数据。 前提条件已注册火山... import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.*; import org.apache.rocketmq.common.message.MessageExt; import org.apache.rock...
RocketMQ 生产者使用建议
本文档介绍 RocketMQ 生产者的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 消息 Tag建议组合使用 Topic 和 tags,以减少 Topic 的使用。 Tag 可以由应用自行设置。 仅当生产者在发送消息时设置了 Tag,消费者在订阅消息时才可以利用 Tag 进行消息过滤,例如 message.setTags("TagA")。消费者在 Broker 侧根据 Tag 的 hashcode 进行初步过滤,在消费端根据字符串过滤...
