RocketMQ/Kafka/RabbitMQ 均采用的是消息刷盘至所部署虚拟机/物理机的文件系统做持久化。ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文... 队列就存放在这个目录中 │ ├── TopicTest1 │ ├── 0 │ └── 00000000000000000000 │ └── 1 │ └── 00...
相关产品:中间件-RocketMQ- 受众: 通用# 实验说明## 第一步、创建RocketMQ实例在控制台创建RocketMQ实例,并配置Topic、Group、以及秘钥,详见[RocketMQ创建文档](https://www.volcengine.com/docs/6410/70793... //此处填写控制台RocketMQ实例概览中的TCP内网接入点,目前不支持公网接入,示例http://MQ_INST_50392uo8m9em_xxxxx.rocketmq.ivolces.com:9876 producer.WithRetry(2), producer.WithCredentials(primitive.Cre...
# 问题描述RocketMQ 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下:1. 客户端 SDK 使用的版本不对, 需要使用 SDK 版本为 4.8.0, 4.7 和 4.9 的版本均会导致前端页... DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName", aclHook,true,null);```* 消费者开启消息轨迹:```javaAclClientRPCHook aclHook = new AclClientRPCHook(new SessionCredential...
RocketMQ与其他消息中间件的一大区别就在于,它采用的是经过实践检验的云原生架构。接下来,我们要探讨RocketMQ在云原生架构领域的关键技术进步。## RocketMQ的云原生发展历程随着消息队列行业的发展,Apache Roc... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。![picture.image](https://p6-volc-community-sign.byteimg.com/to...
在控制台中重新发送死信队列中的消息。此时该消息的原消费者可以重新消费消息。 说明 若此死信消息所在的 Topic 是顺序消息类型的 Topic,重新发送死信消息可能会导致 Topic 出现消息乱序。延迟消息和事务消息也会失去其对应的消息属性。 死信消息被重新发送成功后,也会显示在死信队列中,直到消息过期删除。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 是 rocketmq-cnai81fd122a**** 实例 ID。 G...
死信消息。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明此接口用于查询指定 Group ID 下指定 Message ID 的消息。按消息 ID 查询时,可以精确到某一条消息,适用于精确查询的情况。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 是 rocketmq-cnai1f0c29ca**** 实例 ID。 GroupId String 是 GID_test 死信队列对应的的 Group ID。 创建 Group 时,...
产品功能多种消费类型:消息队列 RocketMQ版提供灵活、可扩展性强的消费主题模式设置,支持发布/订阅、集群消费和广播消费模式。 多种消息类型:消息队列 RocketMQ版支持丰富的消息类型,支持顺序消息、事务消息、定时消息、延时消息等多种消息类型,满足各类场景下的数据消费需求。 多种消息免运维机制:消息队列 RocketMQ版支持消息查询和回溯、消息重试与死信管理等多种消息免运维机制,可配置消费延时、消息堆积等情况下的数据监...
功能描述 发布时间 发布地域 相关文档 V2 版本 API 正式发布 消息队列 RocketMQ版正式发布 V2 版本 OpenAPI,在兼容原有功能的基础上,支持标签管理等新功能。 2023-08-10 全部地域 API 版本说明 2023年7月功能名称 功能描述 发布时间 发布地域 相关文档 云监控指标 实例维度新增 CPU 使用率、内存使用率监控项。 2023-07-19 全部地域 查看监控数据 批量导入或导出 Topic 支持通过上传配置文件的方式批量创建...
死信队列 Group ID。 MessageIds List 必选 7D**** 需导出的 Message ID。 InstanceId String 必选 MQ_INST_***** 实例 ID。 响应参数参数 参数类型 说明 Total Integer 导出的死信消息总数。 ExportHeaders List 导出的消息。 ExportMessages Map 导出的死信消息。内容包括 Messsage ID 和 ExportMessage,ExportMessage的详细信息请参考 ExportMessage。 示例 请求示例json POST https://rocketmq.volc...
队列(Queue)在消息队列 RocketMQ版中,消息存储在每个 Topic 的一个或多个队列中。 位点(Offset)最大位点(MaxOffset):一个分区中统计的当前消息的总条数。 起始位点(MinOffset):分区的起始位置。 消费位点(Consumer... 死信消息消息队列 RocketMQ版支持对未成功消费的消息自动投递重新消费,达到最大重试次数后,若消费依然失败,则表示消费者在正常情况下无法消费此消息,将此类消息称为死信消息。 死信队列消息队列 RocketMQ版在创建...
本文介绍您在使用 Go SDK 接入火山引擎消息队列 RocketMQ版时,需要配置的参数。 消息发送参数配置示例: // 通用的使用方式p, _ := rocketmq.NewProducer( producer.WithNsResolver(primitive.NewPassthroughResolver([]string{"127.0.0.1:9876"})), producer.WithRetry(2), // 在这里添加新的配置参数)参数说明: 参数 是否必选 说明 配置方式 WithGroupName 可选 Producer 组名,即您在火山引擎 RocketMQ 控制台上创建...
使用说明此接口用于指定时间范围的死信消息查询,即根据 Group ID 和死信消息产生的时间范围,查询该 Group ID 在某段时间内产生的所有死信消息。按时间范围查询时,会筛选出符合条件的消息列表,查询到的死信消息可能较多。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 是 rocketmq-cnai1f0c29ca**** 实例 ID。 GroupId String 是 GID_test 死信队列对应的的 Group ID。 创建 Group 时,消息队列...
本文档介绍 RocketMQ 客户端的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 日志配置RocketMQ 的日志一般是单独配置的,业务日志独立管理。日志默认保存在 ${user.home}/logs/rocketmqlogs 目录的 10 个文件中,每个文件大小为 1G,日志文件名为 rocketmq_client.log。有些业务的用户目录的磁盘空间不大,很容易造成磁盘空间不足。您可以通过设置系统变量的方式配置 ...