检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS def start_consume_message(): consumer = PushConsumer('consumer_group'
"credits" or "license" for more information. >>> 如果未安装Python，请使用以下命令安装： yum install python 安装librocketmq库和rocketmq-client-python，具体操作请参考rocketmq-client-python。
dynamic.modify.enable,kafka.new.pod.port,feature.physerver.kafka.topic.modify,message_trace_enable,features.pod.token.access,kafka.ssl.cert.modify.enable
T; } return ConsumeOrderlyStatus.SUCCESS; } }); consumer.start(); System
manager,kafka.ssl.2way.modify.enable,kafka.new.pod.port,message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections
manager,kafka.ssl.2way.modify.enable,kafka.new.pod.port,message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections
nd { "oper_type" : "horizontal", "new_product_id" : "c6.4u8g.cluster" } 响应示例 状态码： 200 实例规格变更成功。 { "job_id" : "93b94287-728d-4bb1-a158-cb66cb0854e7"
"name" : "broker-1" }, { "name" : "broker-2" } ], "result" : "success" } 状态码 状态码 描述 200 操作成功。 错误码 请参见错误码。 父主题： 实例管理
死信队列用于处理无法被正常消费的消息。 一条消息初次消费失败会被重试消费，若重试次数达到最大值（默认16次，在创建RocketMQ消费组中可配置）时，依然消费失败，则其将被投递到该消费者对应的特殊队列（即死信队列）中，这种消息被称为死信消息。 死信消息具有如下特性： 不会再被消费者正常消费。
查看RocketMQ消费组详情 消费组创建成功后，可在控制台查看消费组的相关配置和状态信息。 前提条件 已创建消费组。 查看RocketMQ消费组详情 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件
情页面。 在左侧导航栏，单击“消费组管理”，进入消费组列表页面。 单击“创建消费组”，弹出“创建消费组”页面。 参考表1，填写消费组名称和配置信息。 表1 消费组参数说明 参数 说明 消费组名称 您可以自定义消费组名称，用于区别不同的消费行为。 消费组名称命名规则如下： 长度为3~64个字符。
"enabled": true, "pwd_status": false, "access_mode": "default", "is_domain_owner": false, "xuser_id":
"available_zones": [ "effdcxxxxxx2f56533" ], "product_id": "c6.4u8g.cluster", "storage_spec_code": "dms.physical.storage.high.v2", "broker_num":
通过suspendTimeMillis设置重试时间间隔。 默认值为1000ms，即1s。 通过消费者的setMaxReconsumeTimes函数配置最大重试次数。若未设置参数值，默认为无限重试。 普通消费 重试时间间隔根据重试次数阶梯变化，如表2所示。 创建消费组时设置。 取值范围：1-16。
manager,kafka.ssl.2way.modify.enable,kafka.new.pod.port,message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections
用户在安全组中未放通业务节点的端口。 解决方法 在RocketMQ实例控制台的详情页中，获取“网络 > 需要放通的地址”中的端口号。 单击安全组名称，进入安全组配置页面。 在“入方向规则”中，放通1中的端口号。 父主题： 连接问题
后台任务列表 任务名 说明 创建实例 创建一个RocketMQ实例。 重启实例 重启RocketMQ实例。 修改是否开启SSL 修改SSL的配置。 开启公网访问 修改“公网访问”为开启。 关闭公网访问 修改“公网访问”为关闭。 变更规格 扩容存储空间 扩容代理数量 扩容代理规格 批量删除消费组
查看RocketMQ实例后台任务 配置RocketMQ实例标签 导出RocketMQ实例列表 诊断RocketMQ实例 重启RocketMQ实例的Broker节点 删除RocketMQ实例 配置RocketMQ实例回收站策略 修改RocketMQ实例的SSL配置 开启RocketMQ实例弹性TPS功能
user_name 是 String 用户名。 请求参数 无 响应参数 状态码： 200 表2 响应Body参数 参数 参数类型 描述 access_key String 用户名，只能英文字母开头，且由英文字母、数字、中划线、下划线组成，长度为7~64个字符。 secret_key
参数管理 查询RocketMQ配置 修改RocketMQ配置 父主题： API V2（推荐）
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
