RocketMQ清理
社区干货
RocketMQ 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
# 云原生架构在技术视角下,云原生架构是由一系列针对云原生技术的设计原则和模式构成,其主要目标是在云应用中去除最大限度的非业务代码部分,从而将这些非功能性特性(比如弹性、韧性、安全性、可观察性、灰度等)交... RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间...
干货|字节跳动流式数据集成基于Flink Checkpoint两阶段提交的实践和优化(2)
> > > 字节跳动开发套件数据集成团队(DTS ,Data Transmission Service)在字节跳动内基于 Flink 实现了流批一体的数据集成服务。其中一个典型场景是 Kafka/ByteMQ/RocketMQ -> HDFS/Hive 。Kafka/ByteMQ/RocketMQ... 都由于某个文件被删除造成写入数据或者关闭文件时失败。如 task 0 失败是由于文件/xx/\_DUMP\_TEMPORARY/cp-4608/task-0/date=20211031/18\_xx\_0\_4608.1635674819911.zstd被删除而失败。但是查看正式目录...
如何解决使用RocketMQ的消息轨迹信息无法查看问题
# 问题描述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版控制台中,您可以在线查询死信消息,并在消息被过期清理前,及时导出未正常消费的信息,排查消息生产或消费问题,避免消息丢失。 注意事项一个死信队列对应一个 Group ID, 而不是对应单个消费者实例。一个死信队列包含了对应 Group ID 产生的所有死信消息,不论该消息属于哪个 Topic。 创建 Group 时,消息队列 RocketMQ版会自动为其创建一个对应的死信队列。 死信消息将会根据存储时长被系统定时删除,在查看或导出...
DeleteTopicsFromAuthKey
调用 DeleteTopicsFromAuthKey 接口删除指定 RocketMQ 密钥中的自定义权限。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明此接口支持批量删除指定 RocketMQ 密钥中的多个自定义权限。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 必选 MQ_INST_******** 实例 ID。 Ak String 必选 ak**** RocketMQ 密钥中的 AccessKey ID。 Topics List 必选...
API 概览
消息队列 RocketMQ版提供以下相关 API 接口。 实例管理API 说明 CreateInstance 调用 CreateInstance 接口创建RocketMQ实例。 DeleteInstance 调用 DeleteInstance 接口删除实例。 GetInstance 调用 GetInstance 接口查看指定RocketMQ实例的详细信息。 ListInstances 调用 ListInstances 接口查看当前账号在当前地域下的所有RocketMQ实例信息。 ScaleInstance 调用 ScaleInstance 接口变更实例规格。 EnablePublicN...
DeleteGroups
调用 DeleteGroups 接口,批量删除消费组(ConsumerGroup)。 注意事项请求频率:该接口请求频率限制为 10 次/秒;单用户请求频率限制为 2 次/秒。 使用说明本接口会删除实例下的消费组,删除后不可恢复,请谨慎调用。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 是 rocketmq-cnai1f0c29ca**** 待删除消费组所属的实例 ID。 GroupsId Array of String 是 ["GID_test1","GID_test2"] 待删除的消费组 I...
消息队列 RocketMQ版正式商用通知
消息队列 RocketMQ版产品开始收取服务费用。 生效时间2022年04月26日中午12点。 计费项与价格消息队列 RocketMQ版支持按量付费和包年包月的计费方式,计费项包括计算规格费用与存储规格费用,不同规格的实例定价不同。产品定价的详细信息,请参见计费项与价格。 收费说明消息队列 RocketMQ版在邀测期结束前已向您发出通知,以确定是否继续使用本产品和服务。 如果您在邀测期间创建了 RocketMQ 实例,且邀测期结束后未删除实例,表示希望...
删除 Topic
无需继续使用某个 Topic 时,可以参考本文档删除 Topic。 注意事项删除该 Topic 后,相关的生产者、消费者将会立即停止服务,同时会删除 Topic 的元数据和消息数据,且数据不可恢复,请谨慎操作。 前提条件RocketMQ 实例状态为运行中。 操作步骤登录消息队列 RocketMQ版控制台。 在实例列表页面,单击目标实例名称。 在Topic管理页签,找到需要删除的 Topic,并在其对应的操作列单击删除。 确认待删除的 Topic 名称及对应实例 ID,单击删除...
限制说明
消息队列 RocketMQ版对一些指标和性能进行了限制,请您在使用过程中注意不要超过相应的限制值,避免出现异常。 限制类型 配额 说明 实例数量 5 个 单个地域(Region)内的消息队列 RocketMQ版实例数。您也可以通过... 超出保留时长限制的消息将被过期清理。 死信消息最大保留时长 72 小时 死信消息在服务端的最大保留时长。 可配置为 1~72 小时。默认为 72 小时,即 3 天。 超出保留时长限制的消息将被过期清理。 消费位点最大...
DeleteTopic
调用 DeleteTopic 接口删除 Topic。 注意事项请求频率:该接口请求频率限制为 30 次/秒;单用户请求频率限制为 6 次/秒。 使用说明本接口会删除实例下 Topic 的相关资源,Topic 删除后不可恢复,请谨慎调用。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 是 rocketmq-cnai1f0c29ca**** 待删除 Topic 所属的实例ID。 TopicName String 是 my_topic 待删除 Topic 的名称。 响应参数无 示例 请求示例...
跨服务访问授权
首次使用消息队列 RocketMQ版之前,您需要进行跨服务授权,允许消息队列 RocketMQ版访问当前账号下的其他服务资源,例如 VPC 等。本文介绍跨服务访问授权的相关操作步骤。 注意事项仅首次创建 RocketMQ 实例之前需要进行跨服务访问授权,完成授权后 RocketMQ 可以持续访问其他服务中的资源,直至删除服务关联角色。 服务关联角色的权限由系统生成,无法变更权限。若您需要取消授权,请删除角色。 建议通过火山引擎主账号完成跨服务访问授...
