要实现 Kafka 端到端精确一次语义，必须同时满足：生产者开启幂等性与事务 ID、消费者设置 isolation.level=read_committed、offset 提交与业务操作原子化、Broker 启用事务相关配置。
要让 Kafka 生产者在 Java 中真正支持精确一次（Exactly Once）语义，光开幂等性还不够，必须配合事务机制和正确的隔离级别配置。关键在于消费者端如何读取事务消息——这由 isolation.level 参数控制。
设置 isolation.level = read_committed
这是启用 EOS 消费端保障的前提。该配置告诉消费者：只消费已提交的事务消息，跳过正在进行中或已中止的事务写入的数据。
- 默认值是 read_uncommitted，即“读未提交”，会看到事务中间态消息，无法保证 EOS
- read_committed 会过滤掉 abort 或未 commit 的消息，同时等待事务完成后再投递，是 EOS 必需项
- 该参数需在 KafkaConsumer 实例中显式设置，对生产者无影响
生产者端必须开启幂等 + 事务 ID
消费者设了 read_committed，但生产者没配事务，依然无法达成端到端 EOS。
- 启用幂等：
props.put("enable.idempotence", "true") - 指定唯一事务 ID：
props.put("transactional.id", "txn-123")（不同生产者实例必须用不同 ID） - 自动触发
acks=all和max.in.flight.requests.per.connection=1，无需手动设
消费者位移提交需与事务对齐
单纯设 isolation.level 不足以保证“处理一次且仅一次”，还需确保 offset 提交和业务写入原子化。
立即学习“Java免费学习笔记（深入）”；
- 推荐使用 KafkaConsumer 的 commitSync() 配合事务生产者：在同一个事务内，先 send 处理结果，再 commit offset
- 若用 Kafka Streams 或 Flink，框架已封装 E2E EOS；纯 Consumer + Producer 手动协调时，需调用
producer.sendOffsetsToTransaction() - 避免自动提交（
enable.auto.commit=false），否则 offset 提交与业务逻辑脱钩，易重复消费
Broker 端需启用事务支持
服务端配置不能遗漏，否则客户端事务会失败。
-
transaction.state.log.replication.factor≥ 3（建议，防日志丢失） -
transaction.state.log.min.isr≥ 2（保证事务状态日志高可用） -
log.retention.hours要足够长（事务元数据默认保留 1 周，短于该值可能导致 abort 查不到记录）
