MrLYG opened a new issue, #4840: URL: https://github.com/apache/rocketmq/issues/4840
**ISSUE REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? step1. K8S使用operator部署HA模式集群1master&1slave step1. K8S uses operator to deploy HA mode cluster 1master&1slave  step2. 往集群名为slave-test的topic写入一些数据 step2. Write some data to the topic of the cluster named slave-test   step3.模拟master宕机，关闭master节点 step3. Simulate the master downtime and shut down the master  step4. 启动消费者服务，消费数据该topic数据 step4. Start the consumer service and consume data for the topic data  - What is expected to see? 在master宕机的情况下，slave应当承担数据消费职责，不会影响rocketmq集群内topic的消息消费任务。 In the case of master downtime, the slave should assume the responsibility of data consumption and will not affect the message consumption task of topics in the rocketmq cluster. - What did you see instead? 消费者消费消息失败； Consumer failed to consume message ```C:\Users\liyuangang\AppData\Local\Temp\GoLand\___9go_build_client.exe nameserverF = topicF = SELF_TEST_TOPIC consumerGroupF = slave-test producerGroupF = slave-test time="2022-08-18T15:37:54+08:00" level=info msg="the consumer start beginning" consumerGroup=slave-test messageModel=Clustering unitMode=false time="2022-08-18T15:37:54+08:00" level=info msg="the topic route info changed" changeTo="{\"OrderTopicConf\":\"\",\"queueDatas\":[{\"brokerName\":\"rocketmq-broker-0\",\"readQueueNums\":4,\"writeQueueNums\":4,\"perm\":6,\"topicSy nFlag\":0}],\"brokerDatas\":[{\"cluster\":\"rocketmq-broker\",\"brokerName\":\"rocketmq-broker-0\",\"brokerAddrs\":{\"1\":\"10.53.70.232:23333\"}}]}" changedFrom="<nil>" topic=slave-test time="2022-08-18T15:37:54+08:00" level=warning msg="query topic route from server error" underlayError="topic not exist" time="2022-08-18T15:37:54+08:00" level=warning msg="queryTopicRouteInfoFromServer return nil" topic="%RETRY%slave-test" time="2022-08-18T15:37:54+08:00" level=warning msg="query topic route from server error" underlayError="topic not exist" time="2022-08-18T15:37:54+08:00" level=warning msg="queryTopicRouteInfoFromServer return nil" topic="%RETRY%slave-test" time="2022-08-18T15:37:55+08:00" level=info msg="receive broker's notification to consumer group" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=warning msg="do balance in group failed, the topic does not exist" consumerGroup=slave-test topic="%RETRY%slave-test" time="2022-08-18T15:37:55+08:00" level=warning msg="delete mq from offset table" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=3]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=error msg="fecth offset of mq from broker error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=3]" consumerGroup=slave-test underlayError="broker: rocke tmq-broker-0 address not found" time="2022-08-18T15:37:55+08:00" level=warning msg="query max offset error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=3]" underlayError="the broker [rocketmq-broker-0] does not exist" time="2022-08-18T15:37:55+08:00" level=warning msg="do defaultConsumer, add a new mq failed" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=3]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=warning msg="delete mq from offset table" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=0]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=error msg="fecth offset of mq from broker error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=0]" consumerGroup=slave-test underlayError="broker: rocke tmq-broker-0 address not found" time="2022-08-18T15:37:55+08:00" level=warning msg="query max offset error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=0]" underlayError="the broker [rocketmq-broker-0] does not exist" time="2022-08-18T15:37:55+08:00" level=warning msg="do defaultConsumer, add a new mq failed" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=0]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=warning msg="delete mq from offset table" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=1]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=error msg="fecth offset of mq from broker error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=1]" consumerGroup=slave-test underlayError="broker: rocke tmq-broker-0 address not found" time="2022-08-18T15:37:55+08:00" level=warning msg="query max offset error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=1]" underlayError="the broker [rocketmq-broker-0] does not exist" time="2022-08-18T15:37:55+08:00" level=warning msg="do defaultConsumer, add a new mq failed" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=1]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=warning msg="delete mq from offset table" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=2]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=error msg="fecth offset of mq from broker error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=2]" consumerGroup=slave-test underlayError="broker: rocke tmq-broker-0 address not found" time="2022-08-18T15:37:55+08:00" level=warning msg="query max offset error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=2]" underlayError="the broker [rocketmq-broker-0] does not exist" time="2022-08-18T15:37:55+08:00" level=warning msg="do defaultConsumer, add a new mq failed" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=2]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=warning msg="do balance in group failed, the topic does not exist" consumerGroup=slave-test topic="%RETRY%slave-test" time="2022-08-18T15:37:55+08:00" level=warning msg="delete mq from offset table" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=0]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=error msg="fecth offset of mq from broker error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=0]" consumerGroup=slave-test underlayError="broker: rocke tmq-broker-0 address not found" time="2022-08-18T15:37:55+08:00" level=warning msg="query max offset error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=0]" underlayError="the broker [rocketmq-broker-0] does not exist" time="2022-08-18T15:37:55+08:00" level=warning msg="do defaultConsumer, add a new mq failed" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=0]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=warning msg="delete mq from offset table" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=1]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=error msg="fecth offset of mq from broker error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=1]" consumerGroup=slave-test underlayError="broker: rocke tmq-broker-0 address not found" time="2022-08-18T15:37:55+08:00" level=warning msg="query max offset error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=1]" underlayError="the broker [rocketmq-broker-0] does not exist" time="2022-08-18T15:37:55+08:00" level=warning msg="do defaultConsumer, add a new mq failed" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=1]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=warning msg="delete mq from offset table" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=2]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=error msg="fecth offset of mq from broker error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=2]" consumerGroup=slave-test underlayError="broker: rocke tmq-broker-0 address not found" time="2022-08-18T15:37:55+08:00" level=warning msg="query max offset error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=2]" underlayError="the broker [rocketmq-broker-0] does not exist" time="2022-08-18T15:37:55+08:00" level=warning msg="do defaultConsumer, add a new mq failed" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=2]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=warning msg="delete mq from offset table" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=3]" consumerGroup=slave-test time="2022-08-18T15:37:55+08:00" level=error msg="fecth offset of mq from broker error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=3]" consumerGroup=slave-test underlayError="broker: rocke tmq-broker-0 address not found" time="2022-08-18T15:37:55+08:00" level=warning msg="query max offset error" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=3]" underlayError="the broker [rocketmq-broker-0] does not exist" time="2022-08-18T15:37:55+08:00" level=warning msg="do defaultConsumer, add a new mq failed" MessageQueue="MessageQueue [topic=slave-test, brokerName=rocketmq-broker-0, queueId=3]" consumerGroup=slave-test ``` -- 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]
