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

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

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

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

您可在控制台的Consumer Group管理页面,单击消费状态,查看Consumer提交的最新位点。Consumer消费时,就是从这个位点继续消费。详情请参见查看消费状态

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

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