preinlov opened a new issue #2509:
URL: https://github.com/apache/rocketmq/issues/2509
there are many error logs in broker log as follows, It looks like my client
send heartbeat with new channel each time
2020-12-16 18:39:41 INFO ClientManageThread_2 - new consumer connected,
group: myapplication-consumer-group CONSUME_PASSIVELY CLUSTERING channel:
ClientChannelInfo [channel=[id: 0xdb9dc65f, L:/30.16.4.204:32228 -
R:/clientip:54875], clientId=clientip@quartzPushConsumer@1, language=JAVA,
version=293, lastUpdateTimestamp=1608115181093]
2020-12-16 18:41:49 ERROR NettyServerNIOSelector_3_3 - ProcessRequestWrapper
response to /clientip:54875 failed
java.nio.channels.ClosedChannelException: null
2020-12-16 18:42:01 INFO ClientManageThread_9 - new consumer connected,
group: myapplication-consumer-group CONSUME_PASSIVELY CLUSTERING channel:
ClientChannelInfo [channel=[id: 0x32c769af, L:/30.16.4.204:32228 -
R:/clientip:5505], clientId=clientip@quartzPushConsumer@1, language=JAVA,
version=293, lastUpdateTimestamp=1608115321118]
2020-12-16 18:42:02 WARN ConsumerManageThread_24 - [NOTIFYME]update consumer
offset less than store. clientHost=clientip:5505,
key=mytopic@myapplication-consumer-group, queueId=1, requestOffset=1920741,
storeOffset=1920742
2020-12-16 18:44:19 ERROR NettyServerNIOSelector_3_3 - ProcessRequestWrapper
response to /clientip:5505 failed
java.nio.channels.ClosedChannelException: null
2020-12-16 18:44:21 INFO ClientManageThread_12 - new consumer connected,
group: myapplication-consumer-group CONSUME_PASSIVELY CLUSTERING channel:
ClientChannelInfo [channel=[id: 0x31d1e67c, L:/30.16.4.204:32228 -
R:/clientip:16055], clientId=clientip@quartzPushConsumer@1, language=JAVA,
version=293, lastUpdateTimestamp=1608115461183]
2020-12-16 18:46:34 ERROR NettyServerNIOSelector_3_1 - ProcessRequestWrapper
response to /clientip:16055 failed
java.nio.channels.ClosedChannelException: null
I dont know why the channel connected last time is not ok, the code is as
follows
NettyRemotingClient#invokeSync
final Channel channel = this.getAndCreateChannel(addr);
private Channel getAndCreateChannel(final String addr) throws
InterruptedException {
if (null == addr) {
return getAndCreateNameserverChannel();
}
ChannelWrapper cw = this.channelTables.get(addr);
if (cw != null && cw.isOK()) {
return cw.getChannel();
}
// why every time create new channel
return this.createChannel(addr);
}
----------------------------------------------------------------
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]
