Тестирование взаимосвязанных процессов (в частности, процесса Kafka) с помощью RSpec в Rails
У меня есть приложение rails, которое запускает несколько процессов с мастером
Процесс 1. Потребитель Kafka, использующий Racecar Gem (https://github.com/zendesk/racecar)
Процесс 2: служба, которая рассылает уведомления на основе сообщений, потребляемых процессом 1.
Я хотел бы использовать драгоценный камень Fake Kafka (https://github.com/catawiki/fake-kafka), чтобы опубликовать сообщение в спецификации функции RSpec и потребить это сообщение моим потребителем Racecar, а затем проверить, что служба делает то, что это должно быть сделано.
Как мне запустить процесс Kafka в моей тестовой среде, чтобы я мог проверить, что использование сообщений приводит к правильному конечному поведению службы?