Kafka Streams Exactly-Once 处理语义实践

--- 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 示例 ```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 简化一致性配置，适合对重复敏感的业务处理链路。