GitHub user Yelijah edited a discussion: 触发限流时,普通消息发送失败依然立即就会重试,而没有重试间隔?

```
2024/08/29 11:11:06 rocketmq-queue-producer-2-worker-5 WARN 
[org.apache.rocketmq.client.java.impl.producer.ProducerImpl] [none]  Failed to 
send message, would attempt to resend right now, maxAttempts=5, attempt=2, 
topic=fine_mq_mt280XST_CLIENT_TO_SERVER_EVENT, 
messageId(s)=[0166F1BCE23DCE001A06E180CA0000136E], 
endpoints=ipv4:192.168.101.254:18081, 
clientId=platform-666fb67bdc-94nhs@26@16@b1i6v42l4t
org.apache.rocketmq.client.java.exception.InternalErrorException: 
[request-id=dd7a4ee4-9158-4464-962f-821d86cd43be, response-code=50001] 
org.apache.rocketmq.proxy.common.ProxyException: [PC_SYNCHRONIZED]broker busy, 
start flow control for a while

2024/08/29 11:11:06 rocketmq-queue-producer-2-worker-19 WARN 
[org.apache.rocketmq.client.java.impl.producer.ProducerImpl] [none]  Failed to 
send message, would attempt to resend right now, maxAttempts=5, attempt=3, 
topic=fine_mq_mt280XST_CLIENT_TO_SERVER_EVENT, 
messageId(s)=[0166F1BCE23DCE001A06E180CA0000136E], 
endpoints=ipv4:192.168.101.254:18081, 
clientId=platform-666fb67bdc-94nhs@26@16@b1i6v42l4t
org.apache.rocketmq.client.java.exception.InternalErrorException: 
[request-id=7c329dd1-d5ba-4e09-8977-6a69e9a8a0fe, response-code=50001] 
org.apache.rocketmq.proxy.common.ProxyException: [PC_SYNCHRONIZED]broker busy, 
start flow control for a while

2024/08/29 11:11:06 rocketmq-queue-producer-2-worker-10 WARN 
[org.apache.rocketmq.client.java.impl.producer.ProducerImpl] [none]  Failed to 
send message, would attempt to resend right now, maxAttempts=5, attempt=4, 
topic=fine_mq_mt280XST_CLIENT_TO_SERVER_EVENT, 
messageId(s)=[0166F1BCE23DCE001A06E180CA0000136E], 
endpoints=ipv4:192.168.101.254:18081, 
clientId=platform-666fb67bdc-94nhs@26@16@b1i6v42l4t
org.apache.rocketmq.client.java.exception.InternalErrorException: 
[request-id=37558e9c-5831-449d-979a-cd1bd112f95f, response-code=50001] 
org.apache.rocketmq.proxy.common.ProxyException: [PC_SYNCHRONIZED]broker busy, 
start flow control for a while
```
我设置了五次重试间隔,刚好遇到服务器流控,但是为啥依然是立即重试了5次,而没有间隔呢? 这样连续几次重试全都被限流了。

GitHub link: https://github.com/apache/rocketmq-clients/discussions/827

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org

Reply via email to