Kafka消费者偏移量提交方式分自动与手动：自动提交（enable.auto.commit=true）默认5秒定时提交，易丢数或重复；手动提交（enable.auto.commit=false）需调用commitSync/commitAsync，推荐异步为主、关闭前同步兜底。
自动提交配置：开箱即用但需谨慎
这是 Kafka 默认行为，适合开发测试、日志采集等允许少量重复或丢失的场景。
-
启用自动提交：设置
enable.auto.commit=true（默认值，可不显式写） -
控制提交频率：通过
auto.commit.interval.ms设定间隔，默认 5000 毫秒（5 秒） -
提交时机：不是“消费完才提交”，而是在每次
poll()返回后，后台定时提交上一批拉取到的最大 offset - 注意风险：若消息刚拉取就提交 offset，但后续处理失败或消费者崩溃，该消息将永久丢失；若处理完成但未到提交时间就宕机，则可能被新消费者重复消费
手动提交配置：精准控制 offset 的起点
必须先禁用自动提交，再在业务逻辑中显式调用提交方法，适用于订单、支付等强一致性场景。
-
关闭自动提交：
enable.auto.commit=false（必须显式设置） - 同步提交（commitSync）：阻塞等待 Broker 确认，保证 offset 提交成功后再继续，适合对数据不丢有硬性要求的流程
- 异步提交（commitAsync）：立即返回，不阻塞消费，可配回调函数处理失败情况，适合高吞吐但能容忍极少量提交失败的场景
-
推荐组合用法：日常用
commitAsync()提升性能，但在关闭消费者前调用一次commitSync()做兜底，避免最后一批 offset 丢失
Spring Boot 中常见配置写法
在 application.yml 或 Java 配置类中设置：
- 自动提交：
spring.kafka.consumer.properties.enable.auto.commit: truespring.kafka.consumer.properties.auto.commit.interval.ms: 3000 - 手动提交：
spring.kafka.consumer.properties.enable.auto.commit: false
（业务代码中调用kafkaConsumer.commitSync()或.commitAsync()）
关键细节别忽略
- 无论自动还是手动，提交的是每个分区当前已处理的最大 offset + 1，即下一条待消费位置
- 手动提交时，若在
poll()后未及时提交，且发生消费者重平衡（如扩容缩容），新分配到该分区的消费者会从上次已提交位置开始读，造成重复 - 不要在循环内对每条消息都
commitSync()—— 性能极差；建议批量处理完一批记录后再提交
