我有一个 Rails 应用程序，它与工头一起运行多个进程
流程 1：使用 Racecar Gem ( https://github.com/zendesk/racecar )的 Kafka 消费者
进程 2：根据进程 1 使用的消息发送通知的服务
我想使用 Fake Kafka gem ( https://github.com/catawiki/fake-kafka ) 在 RSpec 功能规范中发布一条消息，并让我的 Racecar 消费者使用这条消息，然后测试该服务做了什么它的意思是。
如何在我的测试环境中运行 Kafka 进程，以便我可以测试消费消息是否会导致服务中的正确最终行为？