CodingOX commented on issue #2456:
URL: https://github.com/apache/rocketmq/issues/2456#issuecomment-736449566
> @CodingOX Could you provide more logs about the
client(~/logs/rocketmqlogs/rocketmq_client.log)?
Here is my client log
```log
2020-12-01 19:19:23,023 INFO RocketmqRemoting - name server address updated.
NEW : [192.168.0.151:9876, 192.168.0.153:9876] , OLD: null
2020-12-01 19:19:23,023 INFO RocketmqClient - user specified name server
address: 192.168.0.151:9876;192.168.0.153:9876
2020-12-01 19:19:23,023 INFO RocketmqClient - Created a new client Instance,
InstanceIndex:0, ClientID:10.37.129.2@42503, ClientConfig:ClientConfig
[namesrvAddr=192.168.0.151:9876;192.168.0.153:9876, clientIP=10.37.129.2,
instanceName=42503, clientCallbackExecutorThreads=12,
pollNameServerInterval=30000, heartbeatBrokerInterval=30000,
persistConsumerOffsetInterval=5000, pullTimeDelayMillsWhenException=1000,
unitMode=false, unitName=null, vipChannelEnabled=false, useTLS=false,
language=JAVA, namespace=null], ClientVersion:V4_7_1, SerializerType:JSON
2020-12-01 19:19:23,023 INFO RocketmqClient - Created new MQClientInstance
for clientId:[10.37.129.2@42503]
2020-12-01 19:19:23,023 INFO RocketmqCommon - Try to start service
thread:PullMessageService started:false lastThread:null
2020-12-01 19:19:23,023 INFO RocketmqClient - PullMessageService service
started
2020-12-01 19:19:23,023 INFO RocketmqCommon - Try to start service
thread:RebalanceService started:false lastThread:null
2020-12-01 19:19:23,023 INFO RocketmqClient - RebalanceService service
started
2020-12-01 19:19:23,023 INFO RocketmqClient - the producer
[CLIENT_INNER_PRODUCER] start OK. sendMessageWithVIPChannel=false
2020-12-01 19:19:23,023 INFO RocketmqClient - the client factory
[10.37.129.2@42503] start OK
2020-12-01 19:19:23,023 INFO RocketmqClient - the producer [producer-wdf-3]
start OK. sendMessageWithVIPChannel=false
2020-12-01 19:19:23,023 INFO RocketmqRemoting - new name server is chosen.
OLD: null , NEW: 192.168.0.151:9876. namesrvIndex = 610
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv4Stack: false
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv4Stack: false
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv4Stack: false
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv6Addresses: false
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv6Addresses: false
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv6Addresses: false
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtilInitializations -
Loopback interface: lo0 (lo0, 0:0:0:0:0:0:0:1%lo0)
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtilInitializations -
Loopback interface: lo0 (lo0, 0:0:0:0:0:0:0:1%lo0)
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtilInitializations -
Loopback interface: lo0 (lo0, 0:0:0:0:0:0:0:1%lo0)
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtil - Failed to get
SOMAXCONN from sysctl and file /proc/sys/net/core/somaxconn. Default: 128
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtil - Failed to get
SOMAXCONN from sysctl and file /proc/sys/net/core/somaxconn. Default: 128
2020-12-01 19:19:23,023 DEBUG io.netty.util.NetUtil - Failed to get
SOMAXCONN from sysctl and file /proc/sys/net/core/somaxconn. Default: 128
2020-12-01 19:19:23,023 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.allocator.type: pooled
2020-12-01 19:19:23,023 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.allocator.type: pooled
2020-12-01 19:19:23,023 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.allocator.type: pooled
2020-12-01 19:19:23,023 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.threadLocalDirectBufferSize: 0
2020-12-01 19:19:23,023 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.threadLocalDirectBufferSize: 0
2020-12-01 19:19:23,023 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.threadLocalDirectBufferSize: 0
2020-12-01 19:19:23,023 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.maxThreadLocalCharBufferSize: 16384
2020-12-01 19:19:23,023 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.maxThreadLocalCharBufferSize: 16384
2020-12-01 19:19:23,023 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.maxThreadLocalCharBufferSize: 16384
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.151:9876] asynchronously
2020-12-01 19:19:23,023 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.151:9876
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.151:9876] success,
AbstractBootstrap$PendingRegistrationPromise@4d465b11(success)
2020-12-01 19:19:23,023 DEBUG io.netty.util.ResourceLeakDetectorFactory -
Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@75422cf9
2020-12-01 19:19:23,023 DEBUG io.netty.util.ResourceLeakDetectorFactory -
Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@75422cf9
2020-12-01 19:19:23,023 DEBUG io.netty.util.ResourceLeakDetectorFactory -
Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@75422cf9
2020-12-01 19:19:23,023 INFO RocketmqClient - the topic[LcfTopic3] route
info changed, old[null] ,new[TopicRouteData [orderTopicConf=null,
queueDatas=[QueueData [brokerName=broker-a, readQueueNums=4, writeQueueNums=4,
perm=6, topicSynFlag=0], QueueData [brokerName=broker-b, readQueueNums=4,
writeQueueNums=4, perm=6, topicSynFlag=0]], brokerDatas=[BrokerData
[brokerName=broker-b, brokerAddrs={0=192.168.0.153:10911,
1=192.168.0.154:10911}], BrokerData [brokerName=broker-a,
brokerAddrs={0=192.168.0.151:10911, 1=192.168.0.152:10911}]],
filterServerTable={}]]
2020-12-01 19:19:23,023 INFO RocketmqClient - updateTopicPublishInfo prev is
not null, TopicPublishInfo [orderTopic=false, messageQueueList=[],
sendWhichQueue=ThreadLocalIndex{threadLocalIndex=null},
haveTopicRouterInfo=false]
2020-12-01 19:19:23,023 INFO RocketmqClient - topicRouteTable.put. Topic =
LcfTopic3, TopicRouteData[TopicRouteData [orderTopicConf=null,
queueDatas=[QueueData [brokerName=broker-a, readQueueNums=4, writeQueueNums=4,
perm=6, topicSynFlag=0], QueueData [brokerName=broker-b, readQueueNums=4,
writeQueueNums=4, perm=6, topicSynFlag=0]], brokerDatas=[BrokerData
[brokerName=broker-b, brokerAddrs={0=192.168.0.153:10911,
1=192.168.0.154:10911}], BrokerData [brokerName=broker-a,
brokerAddrs={0=192.168.0.151:10911, 1=192.168.0.152:10911}]],
filterServerTable={}]]
2020-12-01 19:19:23,023 INFO RocketmqClient - the topic[TBW102] route info
changed, old[null] ,new[TopicRouteData [orderTopicConf=null,
queueDatas=[QueueData [brokerName=broker-a, readQueueNums=8, writeQueueNums=8,
perm=7, topicSynFlag=0], QueueData [brokerName=broker-b, readQueueNums=8,
writeQueueNums=8, perm=7, topicSynFlag=0]], brokerDatas=[BrokerData
[brokerName=broker-b, brokerAddrs={0=192.168.0.153:10911,
1=192.168.0.154:10911}], BrokerData [brokerName=broker-a,
brokerAddrs={0=192.168.0.151:10911, 1=192.168.0.152:10911}]],
filterServerTable={}]]
2020-12-01 19:19:23,023 INFO RocketmqClient - updateTopicPublishInfo prev is
not null, TopicPublishInfo [orderTopic=false, messageQueueList=[],
sendWhichQueue=ThreadLocalIndex{threadLocalIndex=null},
haveTopicRouterInfo=false]
2020-12-01 19:19:23,023 INFO RocketmqClient - updateTopicPublishInfo prev is
not null, TopicPublishInfo [orderTopic=false, messageQueueList=[],
sendWhichQueue=ThreadLocalIndex{threadLocalIndex=null},
haveTopicRouterInfo=false]
2020-12-01 19:19:23,023 INFO RocketmqClient - topicRouteTable.put. Topic =
TBW102, TopicRouteData[TopicRouteData [orderTopicConf=null,
queueDatas=[QueueData [brokerName=broker-a, readQueueNums=8, writeQueueNums=8,
perm=7, topicSynFlag=0], QueueData [brokerName=broker-b, readQueueNums=8,
writeQueueNums=8, perm=7, topicSynFlag=0]], brokerDatas=[BrokerData
[brokerName=broker-b, brokerAddrs={0=192.168.0.153:10911,
1=192.168.0.154:10911}], BrokerData [brokerName=broker-a,
brokerAddrs={0=192.168.0.151:10911, 1=192.168.0.152:10911}]],
filterServerTable={}]]
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.151:10911] asynchronously
2020-12-01 19:19:23,023 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.151:10911
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.151:10911] success,
AbstractBootstrap$PendingRegistrationPromise@1b11171f(success)
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.153:10911] asynchronously
2020-12-01 19:19:23,023 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.153:10911
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.153:10911] success,
AbstractBootstrap$PendingRegistrationPromise@2d710f1a(success)
2020-12-01 19:19:23,023 INFO RocketmqClient - unregister client[Producer:
producer-wdf-3 Consumer: null] from broker[broker-b 0 192.168.0.153:10911]
success
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.154:10911] asynchronously
2020-12-01 19:19:23,023 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.154:10911
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.154:10911] success,
AbstractBootstrap$PendingRegistrationPromise@6bd61f98(success)
2020-12-01 19:19:23,023 INFO RocketmqClient - unregister client[Producer:
producer-wdf-3 Consumer: null] from broker[broker-b 1 192.168.0.154:10911]
success
2020-12-01 19:19:23,023 INFO RocketmqClient - unregister client[Producer:
producer-wdf-3 Consumer: null] from broker[broker-a 0 192.168.0.151:10911]
success
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.152:10911] asynchronously
2020-12-01 19:19:23,023 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.152:10911
2020-12-01 19:19:23,023 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.152:10911] success,
AbstractBootstrap$PendingRegistrationPromise@48aca48b(success)
2020-12-01 19:19:23,023 INFO RocketmqClient - unregister client[Producer:
producer-wdf-3 Consumer: null] from broker[broker-a 1 192.168.0.152:10911]
success
2020-12-01 19:19:23,023 INFO RocketmqClient - unregister client[Producer:
CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-b 0
192.168.0.153:10911] success
2020-12-01 19:19:24,024 INFO RocketmqClient - unregister client[Producer:
CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-b 1
192.168.0.154:10911] success
2020-12-01 19:19:24,024 INFO RocketmqClient - unregister client[Producer:
CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-a 0
192.168.0.151:10911] success
2020-12-01 19:19:24,024 INFO RocketmqClient - unregister client[Producer:
CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-a 1
192.168.0.152:10911] success
2020-12-01 19:19:24,024 INFO RocketmqCommon - Try to shutdown service
thread:PullMessageService started:true
lastThread:Thread[PullMessageService,5,main]
2020-12-01 19:19:24,024 INFO RocketmqClient - the producer
[CLIENT_INNER_PRODUCER] shutdown OK
2020-12-01 19:19:24,024 INFO RocketmqCommon - shutdown thread
PullMessageService interrupt true
2020-12-01 19:19:24,024 INFO RocketmqClient - PullMessageService service end
2020-12-01 19:19:24,024 INFO RocketmqCommon - join thread PullMessageService
elapsed time(ms) 0 90000
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.153:10911] Found: true
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.153:10911] was removed from channel table
2020-12-01 19:19:24,024 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.153:10911
2020-12-01 19:19:24,024 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.151:10911] Found: true
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.151:10911] was removed from channel table
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.151:9876] Found: true
2020-12-01 19:19:24,024 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.151:10911
2020-12-01 19:19:24,024 INFO RocketmqCommon - Try to shutdown service
thread:RebalanceService started:true lastThread:Thread[RebalanceService,5,main]
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.151:9876] was removed from channel table
2020-12-01 19:19:24,024 INFO RocketmqCommon - shutdown thread
RebalanceService interrupt false
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.154:10911] Found: true
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.154:10911] was removed from channel table
2020-12-01 19:19:24,024 INFO RocketmqClient - RebalanceService service end
2020-12-01 19:19:24,024 INFO RocketmqCommon - join thread RebalanceService
elapsed time(ms) 0 90000
2020-12-01 19:19:24,024 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.151:9876
2020-12-01 19:19:24,024 INFO RocketmqClient - the client factory
[10.37.129.2@42503] shutdown OK
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.152:10911] Found: true
2020-12-01 19:19:24,024 INFO RocketmqClient - the producer [producer-wdf-3]
shutdown OK
2020-12-01 19:19:24,024 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.152:10911] was removed from channel table
2020-12-01 19:19:24,024 INFO RocketmqRemoting - shutdown thread
NettyEventExecutor interrupt false
2020-12-01 19:19:24,024 INFO RocketmqRemoting - join thread
NettyEventExecutor elapsed time(ms) 0 90000
2020-12-01 19:19:24,024 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:24,024 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.154:10911
2020-12-01 19:19:24,024 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:24,024 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:24,024 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.152:10911
2020-12-01 19:19:24,024 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:33,033 INFO RocketmqClient - user specified name server
address: 192.168.0.151:9876;192.168.0.153:9876
2020-12-01 19:19:33,033 INFO RocketmqRemoting - name server address updated.
NEW : [192.168.0.151:9876, 192.168.0.153:9876] , OLD: null
2020-12-01 19:19:33,033 INFO RocketmqClient - Created a new client Instance,
InstanceIndex:0, ClientID:10.37.129.2@42510, ClientConfig:ClientConfig
[namesrvAddr=192.168.0.151:9876;192.168.0.153:9876, clientIP=10.37.129.2,
instanceName=42510, clientCallbackExecutorThreads=12,
pollNameServerInterval=30000, heartbeatBrokerInterval=30000,
persistConsumerOffsetInterval=5000, pullTimeDelayMillsWhenException=1000,
unitMode=false, unitName=null, vipChannelEnabled=false, useTLS=false,
language=JAVA, namespace=null], ClientVersion:V4_7_1, SerializerType:JSON
2020-12-01 19:19:33,033 INFO RocketmqClient - Created new MQClientInstance
for clientId:[10.37.129.2@42510]
2020-12-01 19:19:33,033 INFO RocketmqCommon - Try to start service
thread:PullMessageService started:false lastThread:null
2020-12-01 19:19:33,033 INFO RocketmqClient - PullMessageService service
started
2020-12-01 19:19:33,033 INFO RocketmqCommon - Try to start service
thread:RebalanceService started:false lastThread:null
2020-12-01 19:19:33,033 INFO RocketmqClient - RebalanceService service
started
2020-12-01 19:19:33,033 INFO RocketmqClient - the producer
[CLIENT_INNER_PRODUCER] start OK. sendMessageWithVIPChannel=false
2020-12-01 19:19:33,033 INFO RocketmqClient - the client factory
[10.37.129.2@42510] start OK
2020-12-01 19:19:33,033 INFO RocketmqClient - the producer [producer-wdf-3]
start OK. sendMessageWithVIPChannel=false
2020-12-01 19:19:33,033 INFO RocketmqRemoting - new name server is chosen.
OLD: null , NEW: 192.168.0.151:9876. namesrvIndex = 438
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv4Stack: false
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv4Stack: false
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv4Stack: false
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv6Addresses: false
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv6Addresses: false
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv6Addresses: false
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtilInitializations -
Loopback interface: lo0 (lo0, 0:0:0:0:0:0:0:1%lo0)
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtilInitializations -
Loopback interface: lo0 (lo0, 0:0:0:0:0:0:0:1%lo0)
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtilInitializations -
Loopback interface: lo0 (lo0, 0:0:0:0:0:0:0:1%lo0)
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtil - Failed to get
SOMAXCONN from sysctl and file /proc/sys/net/core/somaxconn. Default: 128
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtil - Failed to get
SOMAXCONN from sysctl and file /proc/sys/net/core/somaxconn. Default: 128
2020-12-01 19:19:33,033 DEBUG io.netty.util.NetUtil - Failed to get
SOMAXCONN from sysctl and file /proc/sys/net/core/somaxconn. Default: 128
2020-12-01 19:19:33,033 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.allocator.type: pooled
2020-12-01 19:19:33,033 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.allocator.type: pooled
2020-12-01 19:19:33,033 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.allocator.type: pooled
2020-12-01 19:19:33,033 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.threadLocalDirectBufferSize: 0
2020-12-01 19:19:33,033 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.threadLocalDirectBufferSize: 0
2020-12-01 19:19:33,033 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.threadLocalDirectBufferSize: 0
2020-12-01 19:19:33,033 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.maxThreadLocalCharBufferSize: 16384
2020-12-01 19:19:33,033 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.maxThreadLocalCharBufferSize: 16384
2020-12-01 19:19:33,033 DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.maxThreadLocalCharBufferSize: 16384
2020-12-01 19:19:33,033 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.151:9876] asynchronously
2020-12-01 19:19:33,033 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.151:9876
2020-12-01 19:19:33,033 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.151:9876] success,
AbstractBootstrap$PendingRegistrationPromise@4d465b11(success)
2020-12-01 19:19:33,033 DEBUG io.netty.util.ResourceLeakDetectorFactory -
Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@4546b4c1
2020-12-01 19:19:33,033 DEBUG io.netty.util.ResourceLeakDetectorFactory -
Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@4546b4c1
2020-12-01 19:19:33,033 DEBUG io.netty.util.ResourceLeakDetectorFactory -
Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@4546b4c1
2020-12-01 19:19:33,033 INFO RocketmqClient - the topic[LcfTopic3] route
info changed, old[null] ,new[TopicRouteData [orderTopicConf=null,
queueDatas=[QueueData [brokerName=broker-a, readQueueNums=4, writeQueueNums=4,
perm=6, topicSynFlag=0], QueueData [brokerName=broker-b, readQueueNums=4,
writeQueueNums=4, perm=6, topicSynFlag=0]], brokerDatas=[BrokerData
[brokerName=broker-b, brokerAddrs={0=192.168.0.153:10911,
1=192.168.0.154:10911}], BrokerData [brokerName=broker-a,
brokerAddrs={0=192.168.0.151:10911, 1=192.168.0.152:10911}]],
filterServerTable={}]]
2020-12-01 19:19:33,033 INFO RocketmqClient - updateTopicPublishInfo prev is
not null, TopicPublishInfo [orderTopic=false, messageQueueList=[],
sendWhichQueue=ThreadLocalIndex{threadLocalIndex=null},
haveTopicRouterInfo=false]
2020-12-01 19:19:33,033 INFO RocketmqClient - topicRouteTable.put. Topic =
LcfTopic3, TopicRouteData[TopicRouteData [orderTopicConf=null,
queueDatas=[QueueData [brokerName=broker-a, readQueueNums=4, writeQueueNums=4,
perm=6, topicSynFlag=0], QueueData [brokerName=broker-b, readQueueNums=4,
writeQueueNums=4, perm=6, topicSynFlag=0]], brokerDatas=[BrokerData
[brokerName=broker-b, brokerAddrs={0=192.168.0.153:10911,
1=192.168.0.154:10911}], BrokerData [brokerName=broker-a,
brokerAddrs={0=192.168.0.151:10911, 1=192.168.0.152:10911}]],
filterServerTable={}]]
2020-12-01 19:19:33,033 INFO RocketmqClient - the topic[TBW102] route info
changed, old[null] ,new[TopicRouteData [orderTopicConf=null,
queueDatas=[QueueData [brokerName=broker-a, readQueueNums=8, writeQueueNums=8,
perm=7, topicSynFlag=0], QueueData [brokerName=broker-b, readQueueNums=8,
writeQueueNums=8, perm=7, topicSynFlag=0]], brokerDatas=[BrokerData
[brokerName=broker-b, brokerAddrs={0=192.168.0.153:10911,
1=192.168.0.154:10911}], BrokerData [brokerName=broker-a,
brokerAddrs={0=192.168.0.151:10911, 1=192.168.0.152:10911}]],
filterServerTable={}]]
2020-12-01 19:19:33,033 INFO RocketmqClient - updateTopicPublishInfo prev is
not null, TopicPublishInfo [orderTopic=false, messageQueueList=[],
sendWhichQueue=ThreadLocalIndex{threadLocalIndex=null},
haveTopicRouterInfo=false]
2020-12-01 19:19:33,033 INFO RocketmqClient - updateTopicPublishInfo prev is
not null, TopicPublishInfo [orderTopic=false, messageQueueList=[],
sendWhichQueue=ThreadLocalIndex{threadLocalIndex=null},
haveTopicRouterInfo=false]
2020-12-01 19:19:33,033 INFO RocketmqClient - topicRouteTable.put. Topic =
TBW102, TopicRouteData[TopicRouteData [orderTopicConf=null,
queueDatas=[QueueData [brokerName=broker-a, readQueueNums=8, writeQueueNums=8,
perm=7, topicSynFlag=0], QueueData [brokerName=broker-b, readQueueNums=8,
writeQueueNums=8, perm=7, topicSynFlag=0]], brokerDatas=[BrokerData
[brokerName=broker-b, brokerAddrs={0=192.168.0.153:10911,
1=192.168.0.154:10911}], BrokerData [brokerName=broker-a,
brokerAddrs={0=192.168.0.151:10911, 1=192.168.0.152:10911}]],
filterServerTable={}]]
2020-12-01 19:19:33,033 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.153:10911] asynchronously
2020-12-01 19:19:33,033 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.153:10911
2020-12-01 19:19:33,033 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.153:10911] success,
AbstractBootstrap$PendingRegistrationPromise@1b11171f(success)
2020-12-01 19:19:34,034 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.151:10911] asynchronously
2020-12-01 19:19:34,034 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.151:10911
2020-12-01 19:19:34,034 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.151:10911] success,
AbstractBootstrap$PendingRegistrationPromise@2d710f1a(success)
2020-12-01 19:19:34,034 INFO RocketmqClient - unregister client[Producer:
producer-wdf-3 Consumer: null] from broker[broker-b 0 192.168.0.153:10911]
success
2020-12-01 19:19:34,034 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.154:10911] asynchronously
2020-12-01 19:19:34,034 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.154:10911
2020-12-01 19:19:34,034 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.154:10911] success,
AbstractBootstrap$PendingRegistrationPromise@6bd61f98(success)
2020-12-01 19:19:34,034 INFO RocketmqClient - unregister client[Producer:
producer-wdf-3 Consumer: null] from broker[broker-b 1 192.168.0.154:10911]
success
2020-12-01 19:19:34,034 INFO RocketmqClient - unregister client[Producer:
producer-wdf-3 Consumer: null] from broker[broker-a 0 192.168.0.151:10911]
success
2020-12-01 19:19:34,034 INFO RocketmqRemoting - createChannel: begin to
connect remote host[192.168.0.152:10911] asynchronously
2020-12-01 19:19:34,034 INFO RocketmqRemoting - NETTY CLIENT PIPELINE:
CONNECT UNKNOWN => 192.168.0.152:10911
2020-12-01 19:19:34,034 INFO RocketmqRemoting - createChannel: connect
remote host[192.168.0.152:10911] success,
AbstractBootstrap$PendingRegistrationPromise@48aca48b(success)
2020-12-01 19:19:34,034 INFO RocketmqClient - unregister client[Producer:
producer-wdf-3 Consumer: null] from broker[broker-a 1 192.168.0.152:10911]
success
2020-12-01 19:19:34,034 INFO RocketmqClient - unregister client[Producer:
CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-b 0
192.168.0.153:10911] success
2020-12-01 19:19:34,034 INFO RocketmqClient - unregister client[Producer:
CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-b 1
192.168.0.154:10911] success
2020-12-01 19:19:34,034 INFO RocketmqClient - unregister client[Producer:
CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-a 0
192.168.0.151:10911] success
2020-12-01 19:19:34,034 INFO RocketmqClient - unregister client[Producer:
CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-a 1
192.168.0.152:10911] success
2020-12-01 19:19:34,034 INFO RocketmqCommon - Try to shutdown service
thread:PullMessageService started:true
lastThread:Thread[PullMessageService,5,main]
2020-12-01 19:19:34,034 INFO RocketmqCommon - shutdown thread
PullMessageService interrupt true
2020-12-01 19:19:34,034 INFO RocketmqClient - the producer
[CLIENT_INNER_PRODUCER] shutdown OK
2020-12-01 19:19:34,034 INFO RocketmqClient - PullMessageService service end
2020-12-01 19:19:34,034 INFO RocketmqCommon - join thread PullMessageService
elapsed time(ms) 0 90000
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.153:10911] Found: true
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.153:10911] was removed from channel table
2020-12-01 19:19:34,034 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.153:10911
2020-12-01 19:19:34,034 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.151:10911] Found: true
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.151:10911] was removed from channel table
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.151:9876] Found: true
2020-12-01 19:19:34,034 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.151:10911
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.151:9876] was removed from channel table
2020-12-01 19:19:34,034 INFO RocketmqCommon - Try to shutdown service
thread:RebalanceService started:true lastThread:Thread[RebalanceService,5,main]
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.154:10911] Found: true
2020-12-01 19:19:34,034 INFO RocketmqClient - RebalanceService service end
2020-12-01 19:19:34,034 INFO RocketmqCommon - shutdown thread
RebalanceService interrupt false
2020-12-01 19:19:34,034 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.151:9876
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.154:10911] was removed from channel table
2020-12-01 19:19:34,034 INFO RocketmqClient - the client factory
[10.37.129.2@42510] shutdown OK
2020-12-01 19:19:34,034 INFO RocketmqCommon - join thread RebalanceService
elapsed time(ms) 0 90000
2020-12-01 19:19:34,034 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:34,034 INFO RocketmqClient - the producer [producer-wdf-3]
shutdown OK
2020-12-01 19:19:34,034 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.154:10911
2020-12-01 19:19:34,034 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: begin close
the channel[192.168.0.152:10911] Found: true
2020-12-01 19:19:34,034 INFO RocketmqRemoting - closeChannel: the
channel[192.168.0.152:10911] was removed from channel table
2020-12-01 19:19:34,034 INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CLOSE
192.168.0.152:10911
2020-12-01 19:19:34,034 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:34,034 INFO RocketmqRemoting - eventCloseChannel: the
channel[null] has been removed from the channel table before
2020-12-01 19:19:34,034 INFO RocketmqRemoting - shutdown thread
NettyEventExecutor interrupt false
2020-12-01 19:19:34,034 INFO RocketmqRemoting - join thread
NettyEventExecutor elapsed time(ms) 0 90000
```
----------------------------------------------------------------
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]
