HZL3151904214 commented on issue #1085:
URL:
https://github.com/apache/rocketmq-client-go/issues/1085#issuecomment-1670587718
2023-07-31T09:13:52.19左右出现过mq服务器重启，mq重启之后，就出现了 brokerName=rocketmq-broker-b,
queueId=1的消息堆积，直到2023-07-31T13:13:52.195Z才恢复，offset从529直接跳到了553
恢复正常时候的mq日志如下：
2023-07-31T13:13:52.195Z WARN mq/producer.go:100 fetch offset of
mq from broker success {"consumerGroup": "op_controller_cluster_ph",
"MessageQueue": "MessageQueue [topic=ydocs_op_uplink_porder,
brokerName=rocketmq-broker-b, queueId=1]", "offset": 529}
2023-07-31T13:13:52.195Z DEBUG mq/producer.go:66 do
defaultConsumer, add a new mq {"consumerGroup":
"op_controller_cluster_ph", "MessageQueue": "MessageQueue
[topic=ydocs_op_uplink_porder, brokerName=rocketmq-broker-b, queueId=1]"}
2023-07-31T13:13:52.195Z DEBUG mq/producer.go:66 pull
MessageQueue: 1 sleep 3000 ms for mq: MessageQueue
[topic=ydocs_op_uplink_porder, brokerName=rocketmq-broker-b, queueId=1]
2023-07-31T13:13:52.297Z DEBUG mq/producer.go:66 lock
MessageQueue {"lockOK": true, "consumerGroup":
"op_controller_cluster_ph", "MessageQueue": "MessageQueue
[topic=ydocs_op_uplink_porder, brokerName=rocketmq-broker-b, queueId=1]"}
2023-07-31T13:13:55.196Z WARN mq/producer.go:100 fetch offset of
mq from broker success {"MessageQueue": "MessageQueue
[topic=ydocs_op_uplink_porder, brokerName=rocketmq-broker-b, queueId=1]",
"offset": 529, "consumerGroup": "op_controller_cluster_ph"}
2023-07-31T13:13:57.187Z INFO mq/producer.go:83 update offset
to broker success {"consumerGroup": "op_controller_cluster_ph", "MessageQueue":
"MessageQueue [topic=ydocs_op_uplink_porder, brokerName=rocketmq-broker-b,
queueId=1]", "offset": 553}
--
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: commits-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
