| At-most-once | 先记录位点后处理,故障时可能丢失 |
|---|---|
| At-least-once | 先处理后记录位点,故障时可能重复 |
| Exactly-once | 事务提交或幂等写入,端到端不丢不重 |
Kafka 消费侧相关配置
Kafka 消费侧相关配置
isolation.level=read_committed # 只读已提交事务的消息
enable.auto.commit=false # 手动提交,处理成功后提交引擎宣称的精确一次通常是内部语义,跨系统写外部库时仍要配合幂等键或事务表。