在分布式消息服务RocketMQ控制台,您可实时查看消费组和Topic之间的订阅关系,即某个Topic被哪些消费组订阅了,以及某个消费组订阅了哪些Topic。
前提条件
消费组处于在线状态。
什么是订阅关系
分布式消息服务RocketMQ里的一个消费组代表一个Consumer实例群组。对于大多数分布式应用来说,一个消费组下通常会挂载多个Consumer实例。分布式消息服务RocketMQ的订阅关系主要由Topic+Tag共同组成,即一个消费组下所有的Consumer实例订阅的Topic以及这些Topic中的过滤规则Tag。
同一个消费组下所有的Consumer实例需保持订阅关系一致,否则,消息消费的逻辑就会混乱,甚至导致消息丢失。
查看Topic被哪些消费组订阅
-
登录分布式消息服务RocketMQ控制台,在左侧导航栏单击实例列表。
-
在顶部菜单栏选择地域,如华东1,然后在实例列表中,单击目标实例名称。
-
在左侧导航栏单击Topic管理 ,然后在Topic列表单击目标Topic名称。
您可查看到该Topic的所有在线消费组。示例如下。
查看消费组订阅的Topic
-
登录分布式消息服务RocketMQ控制台,在左侧导航栏单击 实例列表。
-
在顶部菜单栏选择地域,如华东1,然后在实例列表中,单击目标实例名称。
-
在左侧导航栏单击消费组管理 ,然后在消费组列表单击目标消费组名称。您可查看到该消费组的订阅关系,示例如下。