分布式消息服务KAFKA版-删除Kafka消息:前提条件

时间:2024-11-15 17:17:31

前提条件

删除消息前,请先在消费代码中设置“auto.offset.reset”参数。“auto.offset.reset”用来指定当Kafka中没有初始偏移量或者当前偏移量不存在(例如当前偏移量已被删除)时,消费者的消费策略。取值如下:

  • latest:偏移量自动被重置到最晚偏移量。
  • earliest:偏移量自动被重置到最早偏移量。
  • none:向消费者抛出异常。

如果将此配置设置为latest,新增分区时,生产者可能会在消费者重置初始偏移量之前开始向新增加的分区发送消息,从而导致部分消息丢失。

support.huaweicloud.com/usermanual-kafka/kafka_ug_0046.html