tencent cloud

文档反馈

管理消费组

最后更新时间:2023-11-16 16:33:19

    操作场景

    数据订阅 Kafka 版支持对消费组进行管理,包括修改密码、删除消费组、修改消费位点 offset 等。
    同时,用户在消费管理中可查看 Client ID(显示消费该组数据的客户端 ID)、分区编号、消费点、消费点写入分区时间、消费延迟等信息。

    前提条件

    已创建 消费组

    注意事项

    在同一个消费组中,当有其他 Kafka 客户端正在消费数据时,不支持修改消费位点。

    修改消费组密码

    1. 登录 DTS 控制台,在左侧导航选择数据订阅,进入数据订阅页面。
    2. 在数据订阅列表,选择所需的数据订阅,单击订阅名或操作列的查看订阅详情,进入订阅管理页面。
    3. 在订阅管理页面,选择消费管理页,单击操作列的修改密码
    4. 在弹出的对话框,修改密码,单击修改

    删除消费组

    1. 登录 DTS 控制台,在左侧导航选择数据订阅,进入数据订阅页面。
    2. 在数据订阅列表,选择所需的数据订阅,单击订阅名或操作列的查看订阅详情,进入订阅管理页面。
    3. 在订阅管理页面,选择消费管理页,单击操作列的删除
    4. 在弹出的对话框,确认无误后,单击确定
    注意
    删除消费组后,该消费组中的消费点位将被删除,但数据订阅中的数据不会被删除,请谨慎操作。

    修改消费位点 offset

    1. 登录 DTS 控制台,在左侧导航选择数据订阅,进入数据订阅页面。
    2. 在数据订阅列表,选择所需的数据订阅,单击订阅名或操作列的查看订阅详情,进入订阅管理页面。
    3. 在订阅管理页面,选择消费管理页,选择对应的消费组,单击修改 offset
    4. 在弹出的对话框中,选择 offset 对象,单击下一步
    5. 设置消费数据的重置方式,然后单击完成
    从最新位置开始消费:消费位点改为 Kafka 消息的最新位点。
    从最开始位置开始消费:消费位点改为 Kafka 消息最开始存储的位点。
    按时间点进行消费位置重置:用户输入对应的时间,DTS 找到用户输入时间对应的消费位点,然后改为从该消费位点开始消费。 当用户设置的时间超过 Kafka 消息的时间,消费位点将以 Kafka 消息中的最大位点为准;当用户设置的时间早于 Kafka 消息的时间,消费位点将以 Kafka 消息中的最小位点为准。
    
    联系我们

    联系我们,为您的业务提供专属服务。

    技术支持

    如果你想寻求进一步的帮助,通过工单与我们进行联络。我们提供7x24的工单服务。

    7x24 电话支持