检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
ClientException, IOException { final ClientServiceProvider provider = ClientServiceProvider.loadService(); String topic = "yourTransactionTopic";
set_property('property', 'test') msg.set_body('message body') return msg def send_delay_message(): producer = Producer('producerGroup')
ception { TransactionListener transactionListener = new TransactionListener() { @Override public LocalTransactionState
consumer.subscribe("TopicTest", "*"); consumer.registerMessageListener(new MessageListenerOrderly() { @Override
CID_ONSAPI_OWNER、SELF_TEST_C_GROUP、TOOLS_CONSUMER、CID_ONSAPI_PULL、CID_ONSAPI_PERMISSION、CID_ONS-HTTP-PROXY、FILTERSRV_CONSUMER等。这些都是RocketMQ内
charging_mode Object 计费模式。 ios Object 支持的io类型。 support_features Object 支持的特性。 properties Object 产品特性。 available_zones Array of strings 可用分区。 unavailable_zones
义。 FileReader fileReader = new FileReader(file); BufferedReader bufferedReader = new BufferedReader(fileReader); String
Perm: &permGroupPerms, }, } nameTopicPerms:= "topic1" permTopicPerms:= model.GetUserTopicPermsPermEnum().PUB|SUB var listTopicPermsbody
使用客户端连接RocketMQ（开启SSL） 本文主要介绍在Linux系统的命令行模式下连接开启SSL的RocketMQ实例的方法。开启SSL表示客户端和RocketMQ实例进行通信时，数据通过密文传输，安全性更高。 操作视频 本视频演示连接RocketMQ实例的操作。 前提条件
使用客户端连接RocketMQ（关闭SSL） 本文主要介绍在Linux系统的命令行模式下连接关闭SSL的RocketMQ实例的方法。关闭SSL表示客户端和RocketMQ实例进行通信时，数据通过明文传输，性能更好。 操作视频 本视频演示连接RocketMQ实例的操作。 前提条件 已购买RocketMQ实例，并已将
ShowUserRequest{} request.InstanceId = "{instance_id}" request.UserName = "{user_name}" response, err := client.ShowUser(request) if err ==
&model.DeleteUserRequest{} request.InstanceId = "{instance_id}" request.UserName = "{user_name}" response, err := client.DeleteUser(request) if
RI部分找到resource-path（/v3.0/OS-USER/users），拼接起来如下所示。 https://iam.cn-north-4.myhuaweicloud.com/v3.0/OS-USER/users 图1 URI示意图 为查看方便，在每个具体API的URI部
取值范围： c6.4u8g.cluster：单个代理最大Topic数4000，单个代理最大消费组数4000 c6.8u16g.cluster：单个代理最大Topic数8000，单个代理最大消费组数8000 c6.12u24g.cluster：单个代理最大Topic数12000，单个代理最大消费组数12000
x底层的架构不体现，只提供TPS。 4.8.0版本中一个Broker由一个主节点和两个备节点组成，当您购买的Broker数为1时，实际创建3个Broker节点，购买2个Broker时（如图1所示）创建6个Broker节点，以此类推。NameServer为2个节点。 图1 选择代理数量 单可用区 实
在页面右上角，单击“申请扩大配额”。 阅读盘古Doer服务声明后，单击“同意”。 在页面右侧的“盘古Doer”侧边窗口，根据您的需求填写配额调整的相关参数。 单击“确定”，提交申请。 提交申请后，您可以根据返回信息查看处理进展。 立即生效：当目标配额不超过自动生效值，则系统自动审批通过，目标配额将在一
UpdateConsumerGroup body = new UpdateConsumerGroup(); body.withRetryMaxTime(16); body.withName("consumer-group-test");
} err = producer.Start() if err != nil { log.Fatal(err) } defer producer.GracefulStop() for i := 0; i < 10; i++ {
Number 参数解释： 总数。 取值范围： 不涉及。 next_offset Integer 参数解释： 下个分页的offset。 取值范围： 不涉及。 previous_offset Integer 参数解释： 上个分页的offset。 取值范围： 不涉及。 brokers Array
Println(err.Error()) } // Note: start after subscribe err = c.Start() if err != nil { fmt.Println(err.Error()) os.Exit(-1) } time.Sleep(time
