我目前正在评估apachekafka在微服务环境中作为中间件的使用。不仅作为消息队列，还用于聚合其他数据源。Kafka似乎是最合适的人选。大多数的服务都是基于游戏框架的，因此阿克卡流Kafka似乎是与Kafka互动的自然选择。
我用一个消费者和一个发布者原型制作了一个小应用程序，通过json进行通信，非常简单。但是当谈到单元测试时，我变得有点无助。有没有可能以轻量级的方式运行测试，而不是使用正在运行的kafka集群或嵌入式服务器（检查这里）？我也发现这个项目看起来很有前途，但我无法用它来测试我的消费者。这不是正确的工具吗？我有点困惑。