在 Kafka Streams 中对单处理器实现（java）进行单元测试？ [关闭]答案

【问题标题】：Unit test a single processor implementation (java) in Kafka Streams? [closed]在 Kafka Streams 中对单处理器实现（java）进行单元测试？ [关闭]
【发布时间】：2018-01-29 03:13:18
【问题描述】：

遇到的具体问题是mock context、状态存储、window对象传入函数进程。

看起来所有示例，例如 here 和 here 都是流级别的单元测试（例如，mockStreams 或使用 EmbeddedKafkaCluster）。

【问题讨论】：

顺便说一句，我可以建议 Spock 在 Java 中进行测试（我们会，真的是 Groovy）。它使嘲笑变得非常容易和愉快。太容易了，你可能会过火:)
Kafka 1.1（即将发布）添加了可用于单元测试的公共测试工件。详情请查看 KIP-247：cwiki.apache.org/confluence/display/KAFKA/…

标签： java unit-testing apache-kafka-streams

【解决方案1】：

如果您希望测试单个处理器实现，并且需要模拟上下文、状态存储等，我会使用您通常用来模拟事物的任何测试工具（Mockito、CGLIB 等）。

在您的问题范围之外，还有ProcessorTopologyTestDriver。发布以防您错过。 Kafka Streams 在upcoming version 中获得了新的/改进的测试功能。

【讨论】：