apache / apache/rocketmq-client-go

HELP:use of closed network connection

Open
#1,033 10 comments 0 reactions 0 assignees View on GitHub
question
Dominant language
Go
Stars
1.4k
Forks
445
PR merge metrics
No merged PRs in 30d

Description

version info:
Linux version 3.10.0-1160.el7.x86_64 (mockbuild@kbuilder.bsys.centos.org) (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="" 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="" 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."

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.