更新时间:2024-04-07 GMT+08:00
重置消费进度
重置消费进度即修改消费者的消费位置。
重置消费进度可能会导致重复消费,请谨慎操作。
前提条件
Kafka实例不支持在线重置消费进度,请先将待重置消费进度的消费组停止消费,然后重置消费进度。
停止待重置消费进度的消费者客户端后,需要等待一段时间(即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间,默认为1000毫秒),服务端才会认为此消费者已下线。
操作步骤
- 登录管理控制台。
- 在管理控制台左上角单击,选择区域。
请选择Kafka实例所在的区域。
- 在管理控制台左上角单击,选择“应用服务 > 分布式消息服务 Kafka”,进入分布式消息服务Kafka专享版页面。
- 单击Kafka实例的名称,进入实例详情页面。
- 在左侧导航栏选择“消费组管理”,进入消费组列表页面。
- 单击待重置消费进度的消费组名称,进入消费组详情页。
- 在“消费进度”页签,通过以下方法,重置消费进度。
- 重置单个Topic所有分区的消费进度:在待重置消费进度的Topic后,单击“重置消费进度”。
- 重置单个Topic中单个分区的消费进度:在待重置消费进度的Topic分区后,单击“重置消费进度”。
- 在弹出的“重置消费进度”对话框中,参考表1,设置重置消费进度参数。
- 单击“确定”,弹出确认对话框。
- 单击“是”,完成消费进度的重置。
父主题: 消费组管理