场景描述
在RocketMQ中,消费组(Consumer Group)是一种逻辑上的概念,用于标识一组消费者(Consumer)的集合,这些消费者共同消费同一个主题(Topic)的消息。
消费组的概念允许多个消费者同时消费同一个主题的消息,从而实现消息的负载均衡和高可用性。当一个消息发送到RocketMQ中的某个主题时,RocketMQ会将该消息推送给订阅了该Topic的所有消费组中的消费者。
每个消费组可以包含一个或多个消费者,这些消费者可以在同一个应用程序中或不同的应用程序中运行。消费者可以以集群模式(Cluster Mode)或广播模式(Broadcast Mode)进行消费。
在集群模式下,消费组中的消费者以消费者组的形式协同工作,每个消息只会被消费组中的一个消费者消费。RocketMQ会根据消费者的负载均衡策略,将消息分发给不同的消费者,实现消息的负载均衡和高可用性。
在广播模式下,消费组中的每个消费者都会独立消费消息,每个消息会被消费组中的所有消费者都消费一次。广播模式适用于需要所有消费者都处理同一份消息的场景。
消费组的概念使得RocketMQ能够支持水平扩展和容错能力。通过增加消费者数量或部署多个消费者实例,可以提高消费能力和可用性。
需要注意的是,每个消费组在RocketMQ中必须具有唯一的名称,以便区分不同的消费组。同时,每个消费组可以订阅一个或多个Topic,以满足不同业务场景的需求。
消费组列表
1、 进入消费组管理菜单查看消费组列表,若列表为空则新建消费组,创建消费组详情见具体操作步骤。
2、 支持按照集群、Broker和订阅组名查询,下拉选择或者输入查询内容,点击【查询】按钮即可展示需要的订阅组数据。
3、 查看订阅组基本信息,包括订阅组名、BrokerName、BrokerID、起始消费位置、消费机制、是否开启消费,可点击【开启消费】和【关闭消费】进行切换。
Topic列表
“Topic列表”:查看该消费组可消费的topic列表,及消费TPS限制情况。
1、 支持输入关键字进行主题数据搜索。
2、 勾选需要消费的主题,保存确认。
3、 也可选择全部订购或者取消订购。
下载
将勾选的订阅组,导出其配置及路由情况,为excel文件,导出格式如下:
备注:
如果勾选了订阅组,则导出勾选的订阅组;如果没有勾选,则导出该集群,选定broker下的所有订阅组信息。