检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
List）可以实现对RocketMQ实例中生产者和消费者身份的精确识别，达到权限管理的目的。开启ACL权限控制功能后，生产消息和消费消息时，需要鉴权。 前提条件 已购买RocketMQ实例。 开启RocketMQ ACL访问 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
配置RocketMQ实例的公网访问 您需要通过公网地址访问RocketMQ实例时，开启实例的公网访问功能，并设置弹性IP地址。当业务不再使用公网访问功能时，关闭实例的公网访问功能。 前提条件 只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。 开启公网访问 登录管理控制台。
内，网络默认互通。 如果客户端和RocketMQ实例部署在不同VPC中，由于VPC之间逻辑隔离，客户端和RocketMQ实例不能直接通信，需要打通VPC之间的网络。 客户端连接RocketMQ实例的方式如表1所示。 表1 连接方式说明 连接方式 实现方式 参考文档 公网连接 在R
RocketMQ资源的使用范围。 如果华为账号已经能满足您的要求，不需要创建独立的IAM用户进行权限管理，您可以跳过本章节，不影响您使用DMS for RocketMQ的其它功能。 IAM是华为云提供权限管理的基础服务，无需付费即可使用，您只需要为您账号中的资源进行付费。关于IAM的详细介绍，请参见《IAM产品介绍》。
规格：rocketmq.4u8g.cluster*1 总存储空间：高I/O，300GB 用了一段时间后，用户发现RocketMQ实例当前规格无法满足业务需要，于2023/03/20 9:00:00升配为rocketmq.8u16g.cluster*1。因为该RocketMQ实例打算长期使用下去，于2023/03/20
RocketMQ元数据迁移概述 RocketMQ元数据包括Topic和消费组信息，但不包括Topic和消费组生产消息、消费消息的记录。当您需要使用相同的Topic和消费组时，可通过元数据迁移操作将已有的Topic和消费组信息迁移到指定的RocketMQ实例中，无需再手动创建。 R
AccessKey：创建实例时，如果开启了ACL，需要输入用户名。 SecretKey：创建实例时，如果开启了ACL，需要输入用户密钥。 SetKeys：输入消息的Key。 SetTag：输入消息的Tag。 事务消息需要生产者构建一个事务检查器，用于检查确认异常半事务的中间状态，可以返回3种事务状态：
您也可直接在实例列表页面，单击待查看监控数据的实例所在行的“查看监控数据”，进入云监控页面。 在云监控页面，您可以自行选择哪些监控指标需要展示，以及对监控指标进行排序。 例如，在“节点”页签中，只需要展示“消息生产数”和“消息消费数”，请按照如下步骤操作。 在“节点”页签下，单击“设置监控指标”，弹出“设置监控指标”页面。
在“连接信息”区域，单击“弹性TPS”后的，弹出确认开启提示框。 开启弹性TPS能力后，消息收发允许在一定范围内超过基础规格限制的TPS，且超过基础规格外的部分，需要收取额外的弹性规格费用。 关闭弹性TPS能力后，消息收发将限制在基础规格TPS之内。 单击“确定”，开启弹性TPS功能。 父主题： 管理实例
接信息。 RocketMQ实例5.x版本支持gRPC协议，4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发事务消息前，需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5.0
本文介绍了分布式消息服务RocketMQ版提供的SDK语言版本，列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能，降低您使用SDK的难度，推荐使用。 SDK列表 表1提供了分布式消息服务RocketMQ版支持的SDK列表，您可以
正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制，消息老化时间修改后，正常消息的保留时间和死信消息的保留时间都会被修改。 实例创建后，您可以根据业务需要修改消息老化时间。修改老化时间，不会重启实例。消息老化时间默认为48小时。 前提条件 已购买RocketMQ实例。 修改RocketMQ消息保留时间
变更配置后对计费的影响 当前包年/包月RocketMQ实例资源的规格不满足您的业务需要时，您可以在RocketMQ实例控制台发起变更规格操作，变更时系统将按照如下规则为您计算变更费用： 资源升配：新配置价格高于老配置价格，此时您需要支付新老配置的差价。 资源降配：新配置价格低于老配置价格，此时华为云会将新老配置的差价退给您。
订操作，系统将根据资源是否属于五天无理由退订、是否使用代金券和折扣券等条件返还一定金额到您的账户。详细的退订规则请参见云服务退订规则概览。需要注意，如果实例开启了回收站策略，包周期实例退订后，会存入回收站中，此时不会收取实例的费用，但是会按需收取存储空间的费用。如果想要停止计费，请在回收站中删除实例。
默认为postPaid。 is_auto_pay 否 Boolean 下单订购后，是否自动从客户的账户中支付，而不需要客户手动去进行支付。 取值范围： true：是（自动支付） false：否（需要客户手动支付） 默认为手动支付。 period_type 否 String 订购周期类型。 取值范围：
在客户端开启消息轨迹的方法如下： 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 [root@ecs-test sarama]# go version go version go1.16.5 linux/amd64 如果未安装Go，请下载并安装。
上述代码中，相同orderId的消息需要保证顺序，不同orderId的消息不需要保证顺序，所以将orderId作为选择队列的sharding key。 订阅顺序消息 只需要在订阅普通消息的代码基础上增加orderly=True，参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
云服务存在两种部署方式：项目级服务和全局级服务。其中： 项目级服务需要获取项目级别的Token，此时请求body中auth.scope的取值为project。 全局级服务需要获取全局级别的Token，此时请求body中auth.scope的取值为domain。 调用本服务API需要project级别的Token，
消息的通讯方式。 使用异步发送需要客户端实现异步发送回调接口（SendCallback）。即消息发送方在发送了一条消息后，不需要等待服务端响应接着发送第二条消息。发送方通过回调接口接收服务端响应，并处理响应结果。 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
上述代码中，相同orderId的消息需要保证顺序，不同orderId的消息不需要保证顺序，所以将orderId作为选择队列的sharding key。 订阅顺序消息 只需要在订阅普通消息的代码基础上增加consumer.WithConsumerOrder(true)，参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
