检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
PushConsumer, ConsumeStatus def callback(msg): print(msg.id, msg.body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS
message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections,rabbitmq.manage.support,replica_port_standalone
message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections,rabbitmq.manage.support,replica_port_standalone
请联系技术支持 400 DMS.00400128 Invalid public access parameters. 公网访问参数错误。
System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs); return ConsumeOrderlyStatus.SUCCESS
= nil { fmt.Printf("send message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } err = p.Shutdown
= nil { fmt.Printf("send message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } } time.Sleep
PushConsumer, ConsumeStatus def callback(msg): print(msg.id, msg.body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS
feature.physerver.kafka.topic.modify,message_trace_enable,features.pod.token.access,kafka.ssl.cert.modify.enable,roma.user.manage.no.support
消息大小：1KB 生产者线程数：测试rocketmq.4u8g.cluster.small、rocketmq.4u8g.cluster和rocketmq.8u16g.cluster时，生产者线程数输入256，测试rocketmq.12u24g.cluster时，生产者线程数输入640
2000 2000 rocketmq.4u8g.cluster 1 ~ 10 300 ~ 60000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10 300 ~ 90000 25000 8000 8000 rocketmq.12u24g.cluster
message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections,rabbitmq.manage.support,replica_port_standalone
2000 2000 rocketmq.4u8g.cluster 1 ~ 10 300 ~ 60000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10 300 ~ 90000 25000 8000 8000 rocketmq.12u24g.cluster
实例当前规格无法满足业务需要，于2023/03/20 9:00:00升配为rocketmq.8u16g.cluster*1。
{ "engine" : "rocketmq", "versions" : [ "4.8.0" ], "products" : [ { "type" : "cluster.small", "product_id" : "c6.4u8g.cluster.small
每小时弹性TPS费用 = 1小时内增量部分TPS最大值 * 弹性TPS单价 计费示例 以包年/包月计费模式为例，假设您于2023/03/08 15:50:04在“华北-北京四”区域购买了一个包年/包月4.8.0版本的RocketMQ实例（规格：rocketmq.4u8g.cluster.small
{ "resend_results" : [ { "msg_id" : "C0A8149E0000277600000000000B6835", "error_code" : "DMS.00000000", "error_message" : "Success
{ "resend_results" : [ { "msg_id" : "C0A8149E0000277600000000000B6835", "error_code" : "DMS.00000000", "error_message" : "Success
c6.4u8g.cluster.small：单个代理最大Topic数2000，单个代理最大消费组数2000 c6.4u8g.cluster：单个代理最大Topic数4000，单个代理最大消费组数4000 c6.8u16g.cluster：单个代理最大Topic数8000，单个代理最大消费组数
2000 2000 rocketmq.4u8g.cluster 1 ~ 10 300 ~ 60000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10 300 ~ 90000 25000 8000 8000 rocketmq.12u24g.cluster
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
