У меня есть приложение Spring Boot, которое реализует REST API.Когда полезная нагрузка доставляется в API, она оценивается, а затем отправляется в несколько различных тем кафки.При исключениях данные отправляются в еще одну тему кафки.
Мне сложно писать модульные тесты для этого API, так как все функции включают вывод на брокеров kafka, которых нет во время тестирования.Я видел учебные пособия по использованию объекта Embedded Kafka, но все они включают инициализацию и вызов Kafka непосредственно из тестового примера.
Мне удалось сослаться на моего существующего брокера из тестовых случаев, но выполнение этих тестоввнешние зависимости и производит тестовые данные для моих живых тем.Это не то, что я могу развернуть.
У кого-нибудь есть рекомендации по предоставлению фиктивного брокера для некоторых тем, которые создаются в результате тестовых случаев?