Kafka Streams实战-流和状态

本文会介绍：java 有状态操做 使用状态存储 链接两个流 Kafka Streams的timestamps 1. 有状态操做数据库 1.1 转换处理器安全 KStream.transformValues是最基本的有状态方法，下图展现了它工做的原理：服务器 此方法在语义上与KStream.mapValues方法相同，但主要的区别是transformValues能够访问状态存储实例来完成其任务。ap

>>阅读原文<<