Kafka Streams 流处理引擎：拓扑、处理器与状态存储源码精要概述 Kafka Streams 提供内嵌式分布式流处理引擎。本文补充关键函数核心代码、处理链调用关系、时序与类结构，强调实现边界与中性描述。 ...