-
发送定时消息 - 分布式消息服务RocketMQ版
"})), producer.WithRetry(2), ) err := p.Start() if err !
-
批量删除实例 - 分布式消息服务RocketMQ版
fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
重置消费进度 - 分布式消息服务RocketMQ版
表4 queues 参数 参数类型 描述 broker_name String 队列所在的broker。 queue_id Integer 队列ID。 timestamp_offset Long 重置消费进度。 请求示例 重置topic_01主题的消费进度到指定时间点。
-
修改主题 - 分布式消息服务RocketMQ版
请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 read_queue_num 否 Number 总读队列个数。 write_queue_num 否 Number 总写队列个数。 permission 否 String 权限。
-
查询消费组的授权用户列表 - 分布式消息服务RocketMQ版
perm String 权限。 请求示例 查询消费组的授权用户列表。
-
收发事务消息 - 分布式消息服务RocketMQ版
= TransactionMQProducer(gid, check_callback) producer.set_name_server_address(name_srv) producer.start() for n in range(count):
-
连接问题 - 分布式消息服务RocketMQ版
连接问题 RocketMQ是否支持自建Broker连接云上nameserver? 连接实例失败,报错RemotingTooMuchRequestException: sendDefaultImpl call timeout
-
查询RocketMQ配置 - 分布式消息服务RocketMQ版
(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer
-
迁移其他RocketMQ的元数据到RocketMQ实例 - 分布式消息服务RocketMQ版
/bin/mqadmin clusterList -n {nameserver地址及端口号} 例如:“nameserver地址及端口号”为“192.168.0.65:8100”。 sh .
-
批量添加或删除实例标签 - 分布式消息服务RocketMQ版
= client.BatchCreateOrDeleteRocketmqTag(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err
-
什么是分布式消息服务RocketMQ版 - 分布式消息服务RocketMQ版
Producer:从NameServer获取元数据,然后将消息发送到Broker。 Consumer:从NameServer获取元数据,然后从Broker拉取消息。 支持的消息类型 分布式消息服务RocketMQ版支持4种消息类型。
-
发送定时消息 - 分布式消息服务RocketMQ版
= nil { log.Fatal(err) } err = producer.Start() if err !
-
查询实例下所有迁移任务或查询指定迁移任务信息 - 分布式消息服务RocketMQ版
(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer
-
构造请求 - 分布式消息服务RocketMQ版
/users),拼接起来如下所示。
-
支持多少个消费组个数? - 分布式消息服务RocketMQ版
2000 rocketmq.4u8g.cluster 1 ~ 10 300 ~ 600000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10 300 ~ 900000 25000 8000 8000 rocketmq.12u24g.cluster
-
RocketMQ业务迁移 - 分布式消息服务RocketMQ版
/bin/mqadmin clusterList -n {nameserver地址及端口号} 例如:“nameserver地址及端口号”为“192.168.0.65:8100”。 sh .
-
支持多少个Topic? - 分布式消息服务RocketMQ版
2000 rocketmq.4u8g.cluster 1 ~ 10 300 ~ 600000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10 300 ~ 900000 25000 8000 8000 rocketmq.12u24g.cluster
-
发送定时消息 - 分布式消息服务RocketMQ版
body') return msg def send_delay_message(): producer = Producer(gid) producer.set_name_server_address(name_srv) producer.start
-
RocketMQ支持的监控指标 - 分布式消息服务RocketMQ版
>=0 RocketMQ实例节点 1分钟 broker_retention_period 消息保留时间 当前时间与节点保存的最早一条消息的时间的差值 单位:Hours 说明: 2022年5月16号及以后购买的实例,支持此监控项。
-
状态码 - 分布式消息服务RocketMQ版
建议客户端读取相应的Retry-After首部,然后等待该首部指出的时间后再重试。 500 InternalServerError 表明服务端能被请求访问到,但是不能理解用户的请求。 501 Not Implemented 服务器不支持请求的功能,无法完成请求。