（单元）测试 Akka Streams Kafka

Question

我目前正在评估将 Apache Kafka 用作微服务环境中的中间件。不仅可以作为消息队列，还可以用于聚合其他数据源。卡夫卡似乎是完美的选择。大多数服务基于 Play Framework，因此 Akka Stream Kafka 似乎是与 Kafka 交互的自然选择。

我制作了一个带有 Consumer 和 Publisher 的小型应用程序原型，通过 JSON 进行通信，这非常简单。但是当涉及到单元测试时，我变得有点无助。是否可以以轻量级方式运行测试，而不是使用正在运行的 Kafka 集群或嵌入式服务器（检查here）？我还发现this 项目看起来很有希望，但我无法用它测试我的Consumer。这不是正确的工具吗？我有点困惑。

Answer 1

不确定您的问题是否仍然相关，但您看过Alpakka Kafka testkit 吗？