当消费者服务启动后,rmq日志会打印warn日志提示快照队列已经被删除,:
org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService$ConsumeRequest#run方法里:
log.warn("processQueue is dropped without process consume result. messageQueue={}, msgs={}", messageQueue, msgs);
排查原因可能是由于:
org.apache.rocketmq.client.impl.consumer.RebalanceImpl#updateProcessQueueTableInRebalance方法中ProcessQueue被设置为setDropped(true),请问下什么情况下会出现启动的时候会设置为setDropped(true)导致内存的快照ProcessQueue 和 实际的 MessageQueue 不一致,?