检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
服务端在一段时间后如果一直收不到提交或回滚,则发起回查,生产者在收到回查后重新发送事务提交或回滚。消息只有在提交之后才投递给消费者,消费者对回滚的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x
服务端在一段时间后如果一直收不到提交或回滚,则发起回查,生产者在收到回查后重新发送事务提交或回滚。消息只有在提交之后才投递给消费者,消费者对回滚的消息不可见。 收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4
磁盘IO信息。 properties RocketMQExtendProductPropertiesEntity object 功能特性的键值对。 available_zones Array of strings 有可用资源的可用区列表。 unavailable_zones Array
MIIPAgYJKoZIhvcNAQcCo...ggg1BBIINPXsidG9rZ API同时支持使用AK/SK认证,AK/SK认证是使用SDK对请求进行签名,签名过程会自动往请求中添加Authorization(签名认证信息)和X-Sdk-Date(请求发送的时间)请求头。 AK/S
// 每次能接收的最大消息数 maxMessageNum int32 = 16 // 消息不可见时间,在消息被接收后对其他消费者不可见,直到超时。 invisibleDuration = time.Second * 20 ) func main()
设置每次长轮询能接收的最大消息数 int maxMessageNum = 16; // 设置消息不可见时间,在消息被接收后对其他消费者不可见,直到超时。 Duration invisibleDuration = Duration.ofSeconds(15);
参数 是否必选 参数类型 描述 instances 否 Array of strings 实例的ID列表。 action 是 String 对实例的操作:delete。 all_failure 否 String 参数值为reliability,表示删除租户所有创建失败的RocketMQ实例。