qsrg opened a new issue #3929:
URL: https://github.com/apache/rocketmq/issues/3929
rocketmq:4.4.0
I find when broker server crashed，the sync producer will blocked until
timeout in some times，then throws RemotingTimeoutException: wait response on
the channel ...
```
//org.apache.rocketmq.remoting.netty.NettyRemotingAbstract#invokeSyncImpl
// broker 异常宕机可能会导致生产者等待响应直到超时
RemotingCommand responseCommand =
responseFuture.waitResponse(timeoutMillis);
if (null == responseCommand) {
if (responseFuture.isSendRequestOK()) {
throw new
RemotingTimeoutException(RemotingHelper.parseSocketAddressAddr(addr),
timeoutMillis,
responseFuture.getCause());
} else {
throw new
RemotingSendRequestException(RemotingHelper.parseSocketAddressAddr(addr),
responseFuture.getCause());
}
}
```
it seems the message has send to broker, when producer waitResponse the
broker has crashed at the same time， cause producer blocked in `waitResponse`
until timeout 。In this case, producer can't retry，Is this a probleem?
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
