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

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

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

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

您可在控制台的Group 管理页面,找到目标Group,在其操作列,选择更多 > 消费状态,查看Consumer提交的 消费位点。Consumer消费时,从这个位点继续消费。具体操作,请参见查看消费状态

在管理控制台上操作,可以人工移动Broker记录的消费位点。可以往前移动,重复消费,也可以往后移动,跳过消费。

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