| 默认 | enable.auto.commit=true，auto.commit.interval.ms=5000 |
|---|---|
| 风险 | 未处理完的位移已提交，故障后跳过数据 |
| 建议 | 管道类消费关闭自动提交，改为处理后手动提交 |
关闭自动提交
关闭自动提交
enable.auto.commit=false自动提交看似省事，但在“先提交后处理”的语义下，进程崩溃会直接造成数据空洞。
自动提交 enable.auto.commit 的陷阱
开启自动提交后，消费者在后台按 auto.commit.interval.ms 周期提交“poll 到的位移”，与业务处理是否完成无关；处理崩溃时会丢这一段数据。
易错点
- 自动提交周期大于处理时间时崩溃，重复时间段的数据可能被跳过
- 改手动提交后忘记处理 poll 空批的情形，容易出现长时间不提交、lag 假象
数据来源与参考
- Apache Kafka 官方文档：Consumer Configs（enable.auto.commit）