У меня есть приложение kafka, настроенное на использование реестра схемы.V1 приложения была развернута, и в топологии были созданы журналы промежуточных тем (BranchChild, Reduce-State-Store, JoinThis и т. Д.).И у каждого из них была схема, зарегистрированная в реестре схемы.
v2 приложения готово к работе, но имеет значительные изменения топологии.Развертывание по тем же темам / топологии, что и в v1, вызывает повсеместные исключения, поскольку внутренние темы теперь некорректны.Мои «пользовательские» темы оставались непротиворечивыми
Вопрос: есть ли рекомендуемый метод для сброса состояния приложения, кроме удаления всего содержимого и повторного чтения?Будет ли работать удаление всех внутренних государственных хранилищ и тем?kafka-streams.cleanup () не затрагивает реестр, который также необходимо очистить.
У кого-нибудь есть чистое решение / рекомендация для этого?