重置消费进度即修改消费者的消费位置。

                  

                    
说明
                    
重置消费进度可能会导致重复消费，请谨慎操作。
                    
                  
                  

前提条件

Kafka实例不支持在线重置消费进度，请先将待重置消费进度的消费组停止消费，然后重置消费进度。

操作步骤

步骤 1 登录管理控制台。

步骤 2 在管理控制台右上角单击，选择区域。

                    
说明
                    
请选择Kafka实例所在的区域。
                    
                  
                  

步骤 3 在管理控制台左上角单击，选择“企业中间件”-“分布式消息服务”-“Kafka专享版”，进入分布式消息服务Kafka专享版页面。

步骤 4 单击Kafka实例的名称，进入实例详情页面。

步骤 5 在左侧导航栏选择“消费组管理”，进入消费组列表页面。

步骤 6 单击待重置消费进度的消费组名称，进入消费组详情页。

步骤 7 在“消费进度”页签，通过以下方法，重置消费进度。

• 重置单个Topic所有分区的消费进度：在待重置消费进度的Topic后，单击“重置消费进度”。
• 重置单个Topic中单个分区的消费进度：在待重置消费进度的Topic分区后，单击“重置消费进度”。

步骤 8 在弹出的“重置消费进度”对话框中，参考下表，设置重置消费进度参数。

表 重置消费进度参数说明

参数
说明
重置类型
选择重置类型：
时间：重置消费进度到指定的时间。
偏移量：重置消费进度到指定的偏移量。
一键重置消费进度只支持重置消费进度到指定时间。
时间
当“重置类型”为“时间”时，需要设置此参数。
选择重置消费进度的时间点，重置完成后，将从此时间点开始消费。
最早：最早偏移量
自定义：自定义时间点
最晚：最晚偏移量
偏移量
当“重置类型”为“偏移量”时，需要设置此参数。
选择重置消费进度的偏移量，此偏移量不能小于0，重置完成后，将从此偏移量开始消费。

步骤 9 单击“确定”，弹出确认对话框。

步骤 10 单击“是”，完成消费进度的重置。