Модульное тестирование потребителя и производителя kafka в node js

Question

Итак, у нас есть node js api, у которого есть как производитель, так и потребитель kafka. Мы используем kafkajs для создания клиента kafka. Я хотел знать, есть ли библиотека для модульного тестирования производителя и потребителя kafka, с помощью которой я могу вызвать экземпляр kafka в памяти, аналогичный БД в памяти.