t context) { if (!rateLimiter.tryAcquire(msgs.size(),3, TimeUnit.SECONDS)) { return ConsumeConcurrentlyStatus
* 1. 如果本地事务提交成功，则提交消息事务。 * 2. 如果本地事务提交失败，则回滚消息事务。 * 3. 如果本地事务未知异常，则不处理，等待事务消息回查。 * */ transaction
4.8.0版本） 参数 说明 Topic名称 您可以自定义Topic名称，用于区分不同的Topic。 Topic名称命名规则如下： 长度为3~64个字符。 只能由英文字母、数字、百分号、竖线、中划线、下划线组成。 如果Topic名称中包含“%”或“|”，在云监控中会将“%”或“|
在左侧导航栏，选择“迁移上云 > 元数据迁移”，进入迁移任务列表页面。 单击“创建迁移任务”，弹出“创建迁移任务”对话框。 参考表3，设置迁移任务的参数。 表3 迁移任务参数说明 参数 说明 任务类型 选择“自建RocketMQ上云”。 任务名称 您可以自定义迁移任务的名称，用于区分不同的迁移任务。
String 参数解释： 任务数量。 取值范围： 不涉及。 tasks Array of tasks objects 参数解释： 任务列表。 表3 tasks 参数 参数类型 描述 id String 参数解释： 任务ID。 取值范围： 不涉及。 name String 参数解释： 任务名称。
使用自定义细粒度策略，请使用管理员用户登录IAM控制台，按需选择DMS的细粒度权限进行授权操作。DMS for RocketMQ细粒度权限依赖说明请参见表3。 表3 DMS for RocketMQ细粒度权限依赖说明 权限名称 权限描述 权限依赖 dms:instance:list 查看实例列表 无
实例Topic数上限：定义实例可以创建的Topic数量。 实例消费组数上限：定义实例可以创建的消费组数量。 分布式消息服务RocketMQ版5.x基础版支持的产品规格如表2和表3所示。下表中TPS是指以普通消息类型、4KB消息大小为基准计算的每秒收发消息的总条数。如果消息类型为定时消息/延时消息/事务消息，发送消息的
在消费组列表单击目标消费组名称，进入消费组详情页面。 您可查看到该消费组的订阅关系，当订阅关系不一致时，请根据界面提示信息进行处理。 图2 订阅关系一致示例 图3 订阅关系不一致示例 相关文档 如果消费组和Topic的订阅关系不一致，请及时处理，具体请参见实现订阅关系一致。 父主题： 管理消费组
期日”，将RocketMQ实例到期时间统一到各个月的某一天（详细介绍请参见统一包年/包月资源的到期日）。确认配置费用后单击“去支付”。 图3 续费确认 进入支付页面，选择支付方式，确认付款，支付订单后即可完成续费。 统一包年/包月资源的到期日 如果您持有多台到期日不同的Rocke
cluster*1计费。 欠费影响 图3描述了按需计费RocketMQ实例各个阶段的状态。购买后，在计费周期内RocketMQ实例正常运行，此阶段为有效期；当您的账号因按需RocketMQ实例自动扣费导致欠费后，账号将变成欠费状态，RocketMQ实例将陆续进入宽限期和保留期。 图3 按需计费RocketMQ实例生命周期
图2 消息堆积图表 在“创建告警规则”界面，设置告警名称。告警名称需要符合命名规则：只能由中文、英文字母、数字、下划线、中划线组成。 图3 设置告警名称 在“创建告警规则”界面，设置告警策略。 告警策略：连续1次原始值>=10000个时，触发重要告警，每天发送一次告警通知。 图4
transactionID: %v\n", nextIndex, msg.TransactionId) status := nextIndex % 3 dl.localTrans.Store(msg.TransactionId, primitive.LocalTransactionState(status+1))
更多信息请参见变更资源规格费用说明。 到期后影响 图3描述了包年/包月RocketMQ实例各个阶段的状态。购买后，在计费周期内RocketMQ实例正常运行，此阶段为有效期；RocketMQ实例到期而未续费时，将陆续进入宽限期和保留期。 图3 包年/包月RocketMQ实例生命周期 到期预警
是否支持自动创建Topic 不支持。 代理故障场景 实例中部分代理故障时，无法创建、修改和删除Topic，只能查询Topic。 消费组 表3 消费组约束与限制 限制项 约束与限制 创建消费组的数量 消费组的数量根据产品规格确定，不支持修改。 当消费组的数量达到上限后，您无法继续创建消费组。
现TPS不稳定。 资源独享 底层物理资源采用独享型专有资源部署，保障性能的稳定，具备更好的可靠性和可服务性。 单机实例和集群实例的差异 表3 单机实例和集群实例的差异 维度 单机 集群 使用场景 开发测试场景，对性能和可靠性无要求。 生产环境，无法容忍单点故障，有高可用诉求。 部署架构
表页面，当前实例状态显示为 “变更中”。 待状态更新为 “运行中” 后，在“已用/可用存储空间”中可以查看到扩容后的可用存储空间大小。 图3 查看扩容后存储空间 可用存储空间=实际存储空间-用于存储日志的存储空间-格式化磁盘的损耗。 例如，实际扩容存储空间到700GB，用于存储日
参考表1，填写消费组名称和配置信息。 表1 消费组参数说明 参数 说明 消费组名称 您可以自定义消费组名称，用于区别不同的消费行为。 消费组名称命名规则如下： 长度为3~64个字符。 只能由英文字母、数字、百分号、竖线、中划线、下划线组成。 创建消费组后不能修改名称。 关联代理 RocketMQ实例的版本为4
consumer = new DefaultMQPushConsumer("please_rename_unique_group_name_3"); //填入连接地址 consumer.setNamesrvAddr("192.168.0.1:8100");
Key查询：“Topic”选择待查询消息所在的Topic名称，“Message Key”输入待查询消息的Message Key，单击“查询”。 图3 按Message Key查询消息 在待查询消息所在行，单击“查看详情”，查看消息的具体内容。 消息的具体内容包括消息大小、消息的生成时间以及消息的内容。
消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
