---

title: Kafka Streams Exactly-Once 处理语义实践

keywords:

• Kafka Streams
• Exactly Once
• EOSv2
• processing.guarantee
• 事务

description: 在 Kafka Streams 中启用 Exactly-Once v2，提供配置与示例代码，保障端到端处理一致性。

tags:

• EOSv2
• Exactly Once
• Kafka
• Kafka Streams
• processing.guarantee
• 事务
• 后端
• 流处理

categories:

• 文章资讯
• 技术教程

---

Kafka Streams Exactly-Once 处理语义实践

配置要点

• processing.guarantee=exactly_once_v2
• 设置 application.id 与 bootstrap.servers

Java 示例

Properties props = new Properties();
props.put(StreamsConfig.APPLICATION_ID_CONFIG, "app-eos");
props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.EXACTLY_ONCE_V2);
KafkaStreams streams = new KafkaStreams(builder.build(), props);
streams.start();

注意事项

• 外部副作用需自管幂等；Kafka 内部主题与写入由 Streams 事务保障

总结

启用 EOSv2 简化一致性配置，适合对重复敏感的业务处理链路。