在RocketMQ原生控制台中,通过消息检索,能看到消费者的状态有如下四种:
- NOT_ONLINE :消费者不在线
- CONSUMED :消息已经被投递消费
- CONSUMED_BUT_FILTERED :消息已经被投递且被过滤
比如,发布端发布消息topicA,tagA,订阅端订阅topicA,tagB, tagA的消息就被集群消费的消费者忽略掉了
- NOT_CONSUME_YET :消息未被投递
有可能消息发生了堆积,还未被消费;也有可能消费线程hang住了,导致消费线程迟迟没有返回。
微信扫一扫
在RocketMQ原生控制台中,通过消息检索,能看到消费者的状态有如下四种:
比如,发布端发布消息topicA,tagA,订阅端订阅topicA,tagB, tagA的消息就被集群消费的消费者忽略掉了
有可能消息发生了堆积,还未被消费;也有可能消费线程hang住了,导致消费线程迟迟没有返回。
相关推荐