操作场景
说明消息删除后无法恢复,请谨慎操作。
前提条件
删除消息前,请先在客户端中设置“auto.offset.reset”参数。“auto.offset.reset”用来指定当Kafka中没有初始偏移量或者当前偏移量不存在(例如当前偏移量已被删除)时,消费者的消费策略。取值如下:
- latest:偏移量自动被重置到最晚偏移量。
- earliest:偏移量自动被重置到最早偏移量。
- none:向消费者抛出异常。
操作步骤
-
登录管理控制台。
-
在管理控制台右上角单击,选择区域。
说明请选择Kafka实例所在的区域。
-
在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。
-
单击Kafka实例名称,进入实例详情页面。
-
在左侧导航栏选择“Topic管理”,进入Topic列表页面。
-
在待删除消息的Topic所在行,单击“消息删除”,弹出“消息删除”对话框。
-
设置消息删除参数,如下表所示。
图消息删除
表 消息删除参数说明
参数 说明 分区 选择消息所在的分区编号。 偏移量 输入偏移量,此偏移量之前的数据将被删除。
说明如果“偏移量”设置为“-1”,表示删除分区中所有的消息。
如果您输入的偏移量不在指定分区的最早偏移量和最晚偏移量之间,消息将不会被删除。
如果需要删除多个分区的消息,单击“添加分区”,设置需要删除消息的分区和偏移量。每次最多可选择10个分区。
-
单击“确定”,弹出“清理结果”对话框,单击“确定”,完成消息的删除。
图 清理结果