检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
rocketmq.client import Producer, Message topic = 'TopicTest' gid = 'test' name_srv = '192.168.0.1:8100' def create_message(): msg = Message(topic)
RMQ_SYS_TRACE_TOPIC RMQ_SYS_TRANS_OP_HALF_TOPIC TRANS_CHECK_MAX_TIME_TOPIC SELF_TEST_TOPIC OFFSET_MOVED_EVENT rmq_sys_offset_commit_event 父主题： Topic问题
ect_id}/instances/{instance_id}/messages/resend { "group" : "GID_test", "client_id" : "192.168.0.1", "msg_id_list" : [ "id1" ] } 响应示例
回响应，接着发送下一条消息的通讯方式。 使用异步发送需要客户端实现异步发送回调接口（SendCallback）。即消息发送方在发送了一条消息后，不需要等待服务端响应接着发送第二条消息。发送方通过回调接口接收服务端响应，并处理响应结果。 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
switch state { case 1: fmt.Printf("checkLocalTransaction COMMIT_MESSAGE: %v\n", msg) return primitive.CommitMessageState case 2: fmt.Pri
rocketmq.client import Producer, Message topic = 'TopicTest' gid = 'test' name_srv = '192.168.0.1:8100' def create_message(): msg = Message(topic)
"security_group_name" : "security_group_test", "subnet_id" : "0a0f1fcb-f019-458d-b9e5-301867394d50", "subnet_name" : "subnet-test", "subnet_cidr" : "192
rocketmq.client import Producer, Message topic = 'TopicTest' gid = 'test' name_srv = '192.168.0.1:8100' def create_message(): msg = Message(topic)
磁盘IO信息。 properties RocketMQExtendProductPropertiesEntity object 功能特性的键值对。 available_zones Array of strings 有可用资源的可用区列表。 unavailable_zones Array
响应示例 状态码： 200 消费组的授权用户列表成功。 { "policies" : { "access_key" : "test_01", "secret_key" : "**************", "white_remote_address"
error: %s", err.Error()) os.Exit(1) } msg := primitive.NewMessage("test", []byte("Hello RocketMQ Go Client!")) msg.WithProperty("__STARTDELIVERTIME"
@Service @RocketMQMessageListener( topic = "test-topic-1", consumerGroup = "my-consumer_test-topic-1", enableMsgTrace = true ) public
参数 是否必选 参数类型 描述 instances 否 Array of strings 实例的ID列表。 action 是 String 对实例的操作：delete。 all_failure 否 String 参数值为reliability，表示删除租户所有创建失败的RocketMQ实例。
rocketmq.client import Producer, Message topic = 'TopicTest' gid = 'test' name_srv = '192.168.0.1:8100' def create_message(): msg = Message(topic)
见地区和终端节点。 创建RocketMQ实例 如下示例是创建RocketMQ实例的请求消息： { "name": "rocketmq-test", "engine": "reliability", "engine_version": "4.8.0", "storage_space":
回响应，接着发送下一条消息的通讯方式。 使用异步发送需要客户端实现异步发送回调接口（SendCallback）。即消息发送方在发送了一条消息后，不需要等待服务端响应接着发送第二条消息。发送方通过回调接口接收服务端响应，并处理响应结果。 参考如下示例代码，或者通过AsyncProducer
查询项目标签成功。 { "tags" : [ { "key" : "key1", "values" : [ "value-test", "value1" ] }, { "key" : "key2", "values" : [ "value2" ]
/groups 响应示例 状态码： 200 查询主题消费组列表成功。 { "groups" : [ "CID_JODIE_1", "test_consumer" ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6
s/{instance_id}/groups/{group} 响应示例 状态码： 200 查询消费组成功。 { "name" : "test", "enabled" : true, "broadcast" : true, "brokers" : [ "broker-0"
状态码： 200 查询主题的授权用户列表成功 { "policies" : [ ], "total" : 0, "name" : "test" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
