tianliuliu opened a new issue #3651:
URL: https://github.com/apache/rocketmq/issues/3651
int the RocketMQ remoting module
class:
org.apache.rocketmq.remoting.netty.NettyRemotingClient
org.apache.rocketmq.remoting.netty.NettyRemotingServer
```java
this.bootstrap.group(this.eventLoopGroupWorker).channel(NioSocketChannel.class)
.option(ChannelOption.TCP_NODELAY, true)
.option(ChannelOption.SO_KEEPALIVE, false)
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS,
nettyClientConfig.getConnectTimeoutMillis())
.option(ChannelOption.SO_SNDBUF,
nettyClientConfig.getClientSocketSndBufSize())
.option(ChannelOption.SO_RCVBUF,
nettyClientConfig.getClientSocketRcvBufSize())
// should add ChannelOption.WRITE_BUFFER_WATER_MARK config here
```
There is no configuration item WRITE_BUFFER_WATER_MARK
in develop branch
--
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]
