先记住这个答案
Kafka 消费者在处理消息前先提交 offset，若消费者崩溃或重启，已提交的位移无法回滚，导致后续重连时跳过未处理的消息，造成数据丢失。该机制不保证消息被成功处理，仅保证最多一次消费语义。
- 先提交位移即丢消息风险
- 崩溃窗口内未处理消息不可恢复
- 不保证消息被成功处理
at-most-once 的核心机制：位移提交优先于业务处理
Kafka 消费者可通过将 enable.auto.commit 设为 false，并在 poll() 返回后、处理消息前手动调用 commitSync() 来实现 at-most-once。若消费者在提交位移后、执行业务逻辑前崩溃，由于位移已提交，该批次中全部消息均不会被重新消费，从而造成永久丢失。若依赖自动提交，则提交时机由 auto.commit.interval.ms 决定，不一定在处理前发生，但若在处理过程中因间隔到期而提交，也会形成相同窗口。
此行为构成 at-most-once 语义的核心：每条消息最多被消费一次，但一旦提交位移后处理失败，消息即永久丢失。其根本原因在于位移提交与业务处理之间存在非原子操作的间隙，该间隙即为崩溃窗口。
金融交易事件处理中的 at-most-once 风险场景
某系统从 Kafka 消费订单支付事件，需写入账务数据库并发送通知。开发者错误地在每次 poll() 之后立即调用 commitSync() 提交位移，再执行业务逻辑。当一批 10 条消息被拉取并提交位移后，系统在处理至第 3 条消息时断电，重启后消费者从已提交的位移处继续，导致该批次中尚未成功处理的消息（含第 3 条及后续未处理的消息）被永久跳过而丢失。
该场景下，系统通过提前提交位移避免了重复处理，却牺牲了可靠性。代价是未处理完的交易数据永久缺失，影响账务一致性。正确做法应为在业务处理成功后再调用 commitSync()，或采用事务性保证，从而确保不丢失。
at-most-once 适用的边界条件与失效判断
at-most-once 仅适用于可容忍消息丢失的场景，如日志采集、实时监控指标上报。若消息包含状态变更或业务逻辑，此机制将导致数据不一致。其失效关键在于：若消费者处理耗时超过 max.poll.interval.ms，Kafka 会触发再均衡；在 at-most-once 下，位移已提前提交，未处理的消息不会因再均衡而被重新消费，丢失已不可挽回，但不会扩大丢失范围。若位移尚未提交（即采用 at-least-once），则可能发生重复消费，但那属于另一种语义。
若业务不允许丢失，则应明确放弃 at-most-once，改用 at-least-once：禁用自动提交，并在业务处理成功后手动调用 commitSync()。这样做以可能重复消费为代价换取不丢失，代价是增加开发复杂度，需处理异常情况下的偏移量管理与幂等逻辑。
容易答错的地方
- 误以为自动提交可保证消息不丢失
- Kafka
enable.auto.commit=true并不保证消息不丢失。位移提交与消息处理并非原子操作，若消费者在处理前或处理中因自动提交间隔到期而提交位移，随后崩溃，已拉取但未处理的消息将无法重新消费。官方文档未承诺自动提交发生在处理前，实际提交时机取决于auto.commit.interval.ms与处理耗时的关系。 - 混淆 at-most-once 与 exactly-once
- at-most-once 不等于 exactly-once。后者要求跨生产、消费、存储端的原子性保障，通常需配合事务、幂等生产者及流处理框架。at-most-once 仅通过提前提交位移实现，不提供任何补偿机制，不能用于有状态更新场景。
面试官还会怎么问？
如果手动提交但未捕获异常，会丢失消息吗？
不会产生丢失，但可能重复。若在 commitSync() 前崩溃，即提交尚未发生，那么位移未提交，消息会在组再均衡后由其他消费者重新处理，造成重复；若在提交后、处理完成前崩溃，则可能丢失，但这种情况属于提前提交，而非异常未捕获。若手动提交遵循‘处理成功后再提交’的顺序，则异常不会导致丢失，只会增加重复消费可能。
max.poll.interval.ms 设置过大会导致什么后果？
超过该值会触发消费者组再均衡，可能导致正在处理的消息被重新分配，若偏移量未提交，会重复消费；若已提交，则可能丢失未完成处理的消息。
如何判断当前是否处于 at-most-once 模式？
检查位移提交与业务处理的先后关系：若在执行业务逻辑之前提交位移（如 poll() 后立即 commitSync()，或自动提交间隔短于处理耗时），则可判定为 at-most-once；若在成功处理之后再提交位移，则为 at-least-once。不能仅凭 enable.auto.commit 的取值判断，因为自动提交的时机取决于间隔与处理时长，不代表必然先提交后处理。
参考资料
示例用于理解所注明的运行环境与边界；延伸学习可结合原文中的更多案例。