检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
getName(), msgs); return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); consumer.start(); System
application/json X-Sdk-Date: 20240416T095341Z Authorization: SDK-HMAC-SHA256 Access=****************, SignedHeaders=content-type;host;x-sdk-date, Sign
user_name 是 String 用户名。 请求参数 无 响应参数 状态码： 200 表2 响应Body参数 参数 参数类型 描述 access_key String 用户名，只能英文字母开头，且由英文字母、数字、中划线、下划线组成，长度为7~64个字符。 secret_key
dynamic.modify.enable,kafka.new.pod.port,feature.physerver.kafka.topic.modify,message_trace_enable,features.pod.token.access,kafka.ssl.cert.modify.enable
body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS def start_consume_message(): consumer = PushConsumer('consumer_group'
参数 参数类型 描述 trace Array of trace objects 消息轨迹列表。 表4 trace 参数 参数类型 描述 success Boolean 是否成功。 trace_type String 轨迹类型 timestamp Number 时间。 group_name
Array of User objects 用户列表。 total Number 总用户个数。 表4 User 参数 参数类型 描述 access_key String 用户名，只能英文字母开头，且由英文字母、数字、中划线、下划线组成，长度为7~64个字符。 secret_key
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
Message ack status must be either 'success' or 'fail'. It should not be '{status}'. 消息确认status字段值必须为'success'或'fail'，目前为 {status}。 请检查请求字段status是否不符合要求
body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS def start_consume_message(): consumer = PushConsumer('consumer_group')
currentThread().getName(), msgs); return ConsumeOrderlyStatus.SUCCESS; } }); consumer.start(); System
message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } } time.Sleep(5 * time.Minute) err
body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS def start_consume_message(): consumer = PushConsumer('consumer_group')
为300GB，扩容后实例的代理数为2，此时代理的磁盘大小依旧为300GB，但是总磁盘大小为600GB。 rocketmq.4u8g.cluster.small规格不支持扩容代理规格。 前提条件 已创建RocketMQ实例，且实例状态为“运行中”。 变更实例规格 登录管理控制台。 在管理控制台左上角单击，选择区域。
manager,kafka.ssl.2way.modify.enable,kafka.new.pod.port,message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections
B6835", "error_code" : "DMS.00000000", "error_message" : "Success." } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 重发死信消息。 1 2 3 4
B6835", "error_code" : "DMS.00000000", "error_message" : "Success." } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 消费验证。 1 2 3 4 5
"value" : "7F00000123DC6E0BE85808B037820000" }, { "name" : "CLUSTER", "value" : "DmsCluster" }, { "name" : "TAGS",
"reliability" } 响应示例 状态码： 200 批量删除实例成功。 { "results" : [ { "result" : "success", "instance" : "019cacb7-4ff0-4d3c-9f33-f5f7b7fdc0e6" } ] } SDK代码示例
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
