#spring-cloud #apache-kafka-streams #spring-kafka #embedded-kafka #global-state
Вопрос:
Я пишу тестовый класс, в котором есть несколько методов, требующих Кафки. Мое приложение использует глобальное хранилище потоков кафки, и для каждого теста требуется очистить хранилище. Как я могу очистить хранилище для каждого теста без перезапуска EmbeddedKafka или сброса EmbeddedKafka для каждого теста?