检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
错误码说明 100 Continue 继续请求。 这个临时响应用来通知客户端，它的部分请求已经被服务器接收，且仍未被拒绝。 101 Switching Protocols 切换协议。只能切换到更高级的协议。 例如，切换到HTTP的新版本协议。 200 OK 请求成功。 201 Created
require ( github.com/apache/rocketmq-client-go/v2 v2.1.0 ) 生产者开启消息轨迹（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 package main import ( "context" "fmt" "os"
kafka.topic.accesspolicy,enable.kafka.quota.monitor,rocketmq.acl,roma_app_enable,support.kafka.producer.ip,enable.new.authinfo,enable.kafka.quota
kafka.topic.accesspolicy,enable.kafka.quota.monitor,rocketmq.acl,roma_app_enable,support.kafka.producer.ip,enable.new.authinfo,enable.kafka.quota
果Broker故障则会触发主备倒换，且恢复时间较长，为30秒左右。如果Topic关联了多组Broker，Broker故障时，生产流量可自动切换到另一组Broker，可用性更高。 建议使用如下方法处理RocketMQ 4.8.0版本实例仅配置单组Broker的问题： 扩容到两组或更多组Broker。
kafka.topic.accesspolicy,rabbitmq.plugin.management,rocketmq.acl,roma_app_enable,auto_topic_switch,feature.physerver.kafka.user.manager,enable
rocketmq-all-4.9.8-bin-release.zip （可选）如果RocketMQ实例开启了ACL访问控制，执行mqadmin命令时，需要鉴权。 切换到解压后的软件包目录下，在“conf/tools.yml”文件中，增加如下内容。 accessKey:******* secretKey:*******
支持多少个消费组个数？ 更多 远程登录 应用容器化改造介绍 应用容器化改造流程 步骤1：对应用进行分析 步骤2：准备应用运行环境 更多 云服务器卡顿 应用容器化改造介绍 应用容器化改造流程 步骤1：对应用进行分析 步骤2：准备应用运行环境 更多 操作系统相关 应用容器化改造介绍 应用容器化改造流程 步骤1：对应用进行分析
创建用户并授权使用DMS for RocketMQ 如果您需要对您所拥有的DMS for RocketMQ进行精细的权限管理，您可以使用统一身份认证服务 （Identity and Access Management，简称IAM），通过IAM，您可以： 根据企业的业务组织，在您的
kafka.topic.accesspolicy,enable.kafka.quota.monitor,rocketmq.acl,roma_app_enable,support.kafka.producer.ip,enable.new.authinfo,enable.kafka.quota
在单可用区或多可用区中部署实例 副本冗余 使用一主两备架构，备节点通过数据同步的方式保持数据一致。当网络发生异常或节点故障时，通过Raft协议自动切换主备关系，保持数据一致性。 - 数据持久化 业务系统日常运行中可能出现一些小概率的异常事件。部分可靠性要求非常高的业务系统，除了要求实例高
子网，若需要在已有VPC上创建和使用新的子网，请参考为虚拟私有云创建新的子网。 安全组 不同的RocketMQ实例可以重复使用相同的安全组，也可以使用不同的安全组，请根据实际需要进行配置。 使用RocketMQ实例必须添加表2或表3所示安全组规则，其他规则请根据实际需要添加。 创
RocketMQ最佳实践汇总 本文汇总了基于RocketMQ常见应用场景的操作实践，为每个实践提供详细的方案描述和操作指导，帮助用户轻松构建基于RocketMQ的业务。 表1 RocketMQ最佳实践一览表 最佳实践 说明 通过消息幂等实现消息去重 为了防止消息重复消费导致业务处
kafka.topic.accesspolicy,rabbitmq.plugin.management,rocketmq.acl,roma_app_enable,auto_topic_switch,feature.physerver.kafka.user.manager,enable
List）可以实现对RocketMQ实例中生产者和消费者身份的精确识别，达到权限管理的目的。开启ACL权限控制功能后，生产消息和消费消息时，需要鉴权。 约束与限制 仅2021年8月21号后购买的实例，支持设置ACL访问控制。 开启ACL访问控制会导致没有配置认证信息的客户端连接中断。
创建用户时会设置默认的Topic和消费组权限，如果需要修改默认权限，则可以在此处重新为用户设置。管理员默认具有所有权限，无需手动添加。 5.x基础版不支持此操作。 单击用户名称，进入用户详情页面。 在“Topic权限”/“消费组权限”页签中，单击“添加权限”，弹出“添加权限”对话框。 勾选需要添加权限的Topi
在管理控制台左上角单击，选择区域。 不同区域的云服务产品之间内网互不相通。请就近选择靠近您业务的区域，可减少网络时延，提高访问速度。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。
删除RocketMQ消费组 如果消费组不再继续使用，需要清理时，参考本章节删除消费组。 前提条件 已创建消费组。 删除RocketMQ消费组 登录管理控制台。 在管理控制台左上角单击，选择区域。 不同区域的云服务产品之间内网互不相通。请就近选择靠近您业务的区域，可减少网络时延，提高访问速度。
在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在“公网访问”后，单击。 关闭，单击，关闭公网访问。 关闭公网访问后，需要修改对应的安全组规则，才能通过内网成功连接RocketMQ实例。
正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制，消息老化时间修改后，正常消息的保留时间和死信消息的保留时间都会被修改。 实例创建后，您可以根据业务需要修改消息老化时间。修改老化时间，不会重启实例。消息老化时间默认为48小时。 前提条件 已购买RocketMQ实例。 修改RocketMQ消息保留时间
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
