Skip to main content

管理 Consumer Group

本文介绍Consumer Group的基本概念、相关约束以及Consumer Group相关的查看、变更和删除操作。

Consumer Group​

参考 Apache Kafka 的领域模型，Consumer Group 是 Kafka 系统中承载多个消费行为一致的消费者的负载均衡分组。

和 Consumer 不同，Consumer Group 并不是运行实体，而是一个逻辑资源。在 Kafka 中，通过消费者分组内初始化多个消费者实现消费性能的水平扩展以及高可用容灾。

查看 Consumer Group 详情​

操作步骤​

  1. 登录环境控制台，在左侧导航栏单击实例列表 。然后在实例列表中，单击目标实例名称，进入实例内部功能。

  2. 在左侧导航栏单击 Consumer Groups ，然后在 Consumer Groups 页面找到目标 Consumer Group。

  3. 点击目标 Consumer Group，查看概要信息、客户端连接信息、订阅关系、消费进度和相关 Metrics 数据。

重置消费进度​

用户可通过重置消费位点，按需清除堆积的或不想消费的这部分消息再开始消费，或直接跳转到某个时间点消费该时间点之后的消息（不论是否消费过该时间点之前的消息）。

重置消费位点时对应 Consumer Group 必须为 Empty 状态，即 Consumer 必须离线。

操作步骤​

  1. 找到需要重置消费位点的 Consumer Group，在其详情页 点击重置位点 。

  2. 按照实际需求支持如下选择：

    1. 按照相对时间重置：最近 5 分钟、最近 1 小时、最近 24 小时

    2. 按照指定时间点重置进度：自定义时间戳

    3. 按照相对位置重置：最新位点、最早位点

    4. 按照指定位点进行重置：自定义位点

删除 Consumer Group​

删除 Consumer Group 后，Consumer Group 下的所有消费者可能无法消费消息，且之前的状态数据无法恢复。因此首先需要确认业务不再使用，确保 Consumer Group 处于 Dead 或者 Empty 状态。

操作步骤​

  1. 登录环境控制台，在左侧导航栏单击实例列表 。然后在实例列表中，单击目标实例名称，进入实例内部功能。

  2. 在左侧导航栏单击 Consumer Group ，然后在 Consumer Group 列表页面找到目标Consumer Group。

  3. 点击右侧操作按钮，点击删除，完成二次确认后删除。