1. 收不到消息-consumerOffset.json 信息错位
这种情况一般是，手动删除了store/commitlog目录里的数据等非常规手段造成了consumerOffset.json中记录的还是原来的信息，导致consumer收不到消息。
rocketmq的broker，一个消息主题对应多个队列，这些队列的消费进度会记录在consumerOffset.json文件中。所以一旦这个文件中记录的还是老的offset信息，那么既然就消费不到消息。
一个主题对应几个队列，是记录在$home/store/config/topics.json中的。
topics.json同事发现 如果是自动创建topic，则此处值默认是4，对应broker配置文件的defaultTopicQueueNums项目。如果是手动创建，此处值是8。
注意上面这个文件的路径，目前分析来看，即使你在broker的配置文件中指定了storePathRootDir在其他路径，但是topics.json的信息还是在上面读取。因为这个定制配置信息是后加载的。(rocketmq版本 3.5.8)
这种问题处理办法，如果不是生产环境，可以停掉broker然后把store目录删除，重启broker。
此处收不到 消息没有任何报错。
2. 收不到消息-subscription group not exist
这种情况是在broker的配置文件中设置了autoCreateSubscriptionGroup项为false(默认这一项值true)。
解决办法：要么将上述配置项修改成true。要么用命令行创建订阅组。
sh mqadmin updateSubGroup -g test_group -n localhost:9876 -b localhost:10911
注意：这种情况 在pull形式消费时会报错，在push形式消费时没有任何错误。
错误异常代码：
response.setCode(ResponseCode.SUBSCRIPTION_GROUP_NOT_EXIST);
response.setRemark("subscription group not exist, " + requestHeader.getConsumerGroup() + " "
+ FAQUrl.suggestTodo(FAQUrl.SUBSCRIPTION_GROUP_NOT_EXIST));
3. 收不到消息-一般需要定位哪些代码
正常来讲，分为两个方面，一是看producer端发送消息有没有成功，而是看consumer端有没有拿到消息
1. producer端定位broker服务的
com.alibaba.rocketmq.store.CommitLog.putMessage(MessageExtBrokerInner)
看看这个方法的返回的result是不是成功的即可。
详细分析参见我之前写的 rocketmq源码分析2-broker的消息接收
2. consumer端定位broker服务的
com.alibaba.rocketmq.broker.processor.PullMessageProcessor.processRequest(Channel, RemotingCommand, boolean)
看看能不能走到方法体中的case found分支即可。
详细分析参见我之前写的 rocketmq源码分析3-consumer消息获取
4. 消费完的消息 哪去了
我们在消费完消息后，如果是push的形式 我们会回一个success的状态，如果是pull的形式我们会更新offset。此处可以看到，消费完之后，更新的消息消费的offset，以使mq不会再定时push给你。
那么消费完的消息在broker上还在不在？答案是在的，硬盘上有存储。因为我们可以通过根据消息id查看的消息的方式找到消息。
MessageExt viewMessage = consumer.viewMessage("0A00007400002A9F0000000000010C5E");
当然，rocketmq允许你配置，消息留存多长时间，以及每天几点清除。
--EOF--