Spring Boot中如何为单个Kafka消费者设置auto-offset-reset为earliest

你遇到的问题核心是配置键名错误，Kafka的原生配置属性使用点分隔符，而非连字符，所以auto-offset-reset无法被正确识别，应该改用auto.offset.reset。

正确的@KafkaListener配置示例 #

@KafkaListener(topics = "#{'${app.kafka.mytopic}'}",
               groupId = "#{'${app.kafka.group-id}'}",
               properties = {"auto.offset.reset=earliest"})
public void consumeAllEvents(Event event) {
    // 消费逻辑
}

额外注意事项 #

• 如果你的消费者组已经在Kafka集群中存在偏移量记录，auto.offset.reset配置不会生效——这个配置仅在消费者组没有已提交的偏移量，或者偏移量无效（比如分区被删除）时才会触发。
  • 解决方法1：使用一个全新的groupId，这样集群中没有该组的偏移量记录，配置会生效。
  • 解决方法2：手动重置该消费者组的偏移量，可以通过Kafka命令行工具执行：

    kafka-consumer-groups.sh --bootstrap-server <你的Kafka地址> --group <你的groupId> --reset-offsets --to-earliest --topic <你的topic> --execute
    

内容的提问来源于stack exchange，提问作者Smaillns