zhongkaiuu opened a new issue #1921: one of broker crashed,producer select other broker success,but throws MQClientException URL: https://github.com/apache/rocketmq/issues/1921 **BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? we set retryTimesWhenSendFailed=3 we set send timeout=3000 we set sendLatencyFaultEnable=false we have 4 broker(broker-a,broker-b,broker-c,broker-d), make broker-a crash. producer send message but throws org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [3000]ms, Topic: xxxx, BrokersSent: [broker-a, broker-b, broker-c] - What did you expect to see? broker-a crashed,retry broker-b success,don't throws Exception - What did you see instead?  picture1 has select broker-b and broker-c,but sendtime is 0.  picture2 is rocketmq_client.log,we can see send broker-a is timeout,but broker-b and broker-c timeout is 0.  picture3 is console message page.there is two success message from broker-b and broker-c.  DefaultMQProducerImpl.sendDefaultImpl(), broker-a is costtime=3000. if (timeout < costTime) should be if (timeout <= costTime) ? NettyRemotingAbstract.invokeSyncImpl() // timeoutMillis is zero, can't wait response. this is why broker-b and broker-c has success message,but throws Exception. `RemotingCommand responseCommand = responseFuture.waitResponse(timeoutMillis);` 2. Please tell us about your environment: rocketmq-client and broker are 4.3.2 3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc): maybe client can reset timeout when retry other broker?
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
