Jimmy01010 opened a new issue, #1033: URL: https://github.com/apache/rocketmq-client-go/issues/1033
version info： Linux version 3.10.0-1160.el7.x86_64 ([email protected]) (gcc version 4.8.5 20150623 (Red Hat 4.8.5-44) (GCC) ) golang：go1.19.4 linux/amd64 SDK：github.com/apache/rocketmq-client-go/v2 v2.1.2-0.20230328074514-6c77b6792c22 problem description： 三个消费组实例，其他两个运行正常，一个正常消费十几分钟后挂掉了。 Three consumption group instances, the other two are running normally, one normal consumption after ten minutes of hanging. PS：可能不是bug，请大佬看看问题在哪？或者如何排查。 ---------------------------------log---------------------------------- time="2023-04-09T21:43:47+08:00" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=pickConfigs, brokerName=broker-a, queueId=3]" consumerGroup=config_consumer_pick offset=318653 time="2023-04-09T21:43:47+08:00" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=pickConfigs, brokerName=broker-a, queueId=0]" consumerGroup=config_consumer_pick offset=318651 time="2023-04-09T21:43:47+08:00" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%config_consumer_pick, brokerName=broker-a, queueId=0]" consumerGroup=config_consumer_pick offset=98 time="2023-04-09T21:43:49+08:00" level=info msg="the topic route info changed" changeTo="{\"OrderTopicConf\":\"\",\"queueDatas\":[{\"brokerName\":\"broker-a\",\"readQueueNums\":4,\"writeQueueNums\":4,\"perm\":6,\"topicSynFlag\":0}],\"brokerDatas\":[{\"cluster\":\"DefaultCluster\",\"brokerName\":\"broker-a\",\"brokerAddrs\":{\"0\":\"172.19.19.141:10911\"}}]}" changedFrom="<nil>" topic=test_topic time="2023-04-09T21:43:49+08:00" level=info msg="The RMQClient stopping do rebalance" clientID=172.19.19.131@25561 time="2023-04-09T21:43:49+08:00" level=info msg="The RMQClient stopping update topic route info." clientID=172.19.19.131@25561 time="2023-04-09T21:43:49+08:00" level=info msg="will remove client from clientMap" clientID=172.19.19.131@25561 time="2023-04-09T21:43:49+08:00" level=info msg="The RMQClient stopping persist offset" clientID=172.19.19.131@25561 time="2023-04-09T21:43:49+08:00" level=info msg="The RMQClient stopping update name server domain info." clientID=172.19.19.131@25561 time="2023-04-09T21:43:49+08:00" level=info msg="The RMQClient stopping clean off line broker and heart beat" clientID=172.19.19.131@25561 time="2023-04-09T21:43:53+08:00" level=info msg="the topic route info changed" changeTo="{\"OrderTopicConf\":\"\",\"queueDatas\":[{\"brokerName\":\"broker-a\",\"readQueueNums\":4,\"writeQueueNums\":4,\"perm\":6,\"topicSynFlag\":0}],\"brokerDatas\":[{\"cluster\":\"DefaultCluster\",\"brokerName\":\"broker-a\",\"brokerAddrs\":{\"0\":\"172.19.19.141:10911\"}}]}" changedFrom="<nil>" topic=test_topic time="2023-04-09T21:43:53+08:00" level=info msg="will remove client from clientMap" clientID=172.19.19.131@25561 time="2023-04-09T21:43:53+08:00" level=info msg="The RMQClient stopping do rebalance" clientID=172.19.19.131@25561 time="2023-04-09T21:43:53+08:00" level=info msg="The RMQClient stopping update topic route info." clientID=172.19.19.131@25561 time="2023-04-09T21:43:54+08:00" level=info msg="sending heartbeat, but no producer and no consumer" clientId=172.19.19.131@25561 time="2023-04-09T21:43:54+08:00" level=info msg="The RMQClient stopping clean off line broker and heart beat" clientID=172.19.19.131@25561 time="2023-04-09T21:44:03+08:00" level=info msg="The RMQClient stopping persist offset" clientID=172.19.19.131@25561 time="2023-04-09T21:44:03+08:00" level=info msg="The RMQClient stopping update name server domain info." clientID=172.19.19.131@25561 time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:18+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="request timeout" time="2023-04-09T21:44:21+08:00" level=error msg="conn error, close connection" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=error msg="conn error, close connection" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=error msg="conn error, close connection" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=error msg="conn error, close connection" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=error msg="conn error, close connection" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=error msg="conn error, close connection" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=error msg="conn error, close connection" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=error msg="conn error, close connection" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="set tcp 172.19.19.131:60520: use of closed network connection" time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="unknown Response Code: 24, remark: the consumer's group info not exist\nSee http://rocketmq.apache.org/docs/faq/ for further details." time="2023-04-09T21:44:21+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="unknown Response Code: 24, remark: the consumer's group info not exist\nSee http://rocketmq.apache.org/docs/faq/ for further details." time="2023-04-09T21:44:24+08:00" level=warning msg="pull message from broker error" broker="172.19.19.141:10911" underlayError="unknown Response Code: 24, remark: the consumer's group info not exist\nSee http://rocketmq.apache.org/docs/faq/ for further details." -- 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]
