如何在控制台管理Consumer的offset?

本文为您介绍Consumer在读取消息异常中断后,如何在控制台管理Consumer的offset。

消费位点的提交机制

消费消息并不保证会提交消费位点,Broker记录的是客户端提交的消费位点。

提交消费位点的机制取决于您使用的客户端SDK,一般支持以下两种机制:

  • 自动提交:按照时间间隔,SDK把消费过的最新消息的位点+1提交上去。

  • 手动提交:在应用程序里,把消费过的最新消息的位点+1提交上去。

操作步骤

  1. 查看消费位点

    Topic 详情页面的订阅关系页签,单击目标Topic操作列的消费详情,查看Consumer提交的消费位点。Consumer消费时,从这个位点继续消费。具体操作,请参见查看消费状态

  2. 重置消费位点

    Group 详情页面,单击重置消费位点,在重置Group的消费位点面板,设置重置策略进行重置消费位点。具体操作,请参见重置消费位点

    重要

    在控制台上重置消费位点时,需要先停止消费客户端。否则,重置的结果很可能被消费端覆盖。