在 Kafka Streams 中对单个处理器实现 (java) 进行单元测试？
Unit test a single processor implementation (java) in Kafka Streams?
遇到的具体问题是mocking context，state stores，和window objects pass into the function process
看起来所有示例，例如，here and here 都是流级别的单元测试（例如，mockStreams，或使用 EmbeddedKafkaCluster）。
如果您要测试单个处理器实现，并且需要模拟上下文、状态存储等，我会使用您通常用来模拟事物的任何测试工具（Mockito、CGLIB 等）。
超出你的问题范围，还有 . Posting in case you missed it. Kafka Streams is getting new/improved testing functionality in an upcoming version.
遇到的具体问题是mocking context，state stores，和window objects pass into the function process
看起来所有示例，例如，here and here 都是流级别的单元测试（例如，mockStreams，或使用 EmbeddedKafkaCluster）。
如果您要测试单个处理器实现，并且需要模拟上下文、状态存储等，我会使用您通常用来模拟事物的任何测试工具（Mockito、CGLIB 等）。
超出你的问题范围，还有