NAND86 opened a new issue #583: URL: https://github.com/apache/rocketmq-client-go/issues/583
**BUG REPORT** **Please add the branch name [Native]/[Master] at the header of the Isssue title.** 1. Please describe the issue you observed: 顺序消费者正常消费，打印日志时发生崩溃。 具体崩溃在的第495行 https://github.com/apache/rocketmq-client-go/blob/be579956f83854915f9742578e8db81860b71112/consumer/push_consumer.go#L488-L504 2. Please tell us about your environment: - What is your OS? linux - What is your client version? 2.0.0 - What is your RocketMQ version? 4.3.2 3. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc): 怀疑是积压的消息量太大，消费速度太快，超出阈值后打印日志。 日志打印时，key为count，value为pq.msgCache。 msgCache的数据量很大，且msgCache未加锁访问，可能访问空指针导致崩溃。 在用go race检查时发现这里确实有写冲突。 我们的规避方法很粗暴，直接注释日志中count的打印。去掉之后race也少了很多。 此外，key为count，却打印所有msgCache也很奇怪吧，这里本意是打印数量？ ---------------------------------------------------------------- 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]
