本文为您介绍Consumer在读取消息异常中断后,如何在控制台管理Consumer的offset。
消费位点的提交机制
消费消息并不保证会提交消费位点,Broker记录的是客户端提交的消费位点。
提交消费位点的机制取决于您使用的客户端SDK,一般支持以下两种机制:
自动提交:按照时间间隔,SDK把消费过的最新消息的位点+1提交上去。
手动提交:在应用程序里,把消费过的最新消息的位点+1提交上去。
操作步骤
文档内容是否对您有帮助?
本文为您介绍Consumer在读取消息异常中断后,如何在控制台管理Consumer的offset。
消费消息并不保证会提交消费位点,Broker记录的是客户端提交的消费位点。
提交消费位点的机制取决于您使用的客户端SDK,一般支持以下两种机制:
自动提交:按照时间间隔,SDK把消费过的最新消息的位点+1提交上去。
手动提交:在应用程序里,把消费过的最新消息的位点+1提交上去。