нет и менялись брокеры? Рекомендую остановить кластер, удалить все данные из папки хранения данных (логов) кафки и папку version-2 зукипера. То есть - реинициализировать кластер. Разбираться, почему закоррапчена мапа топиков-партиций будет сильно дольше.
Именно так и делал, выносом данных zk и kafka log.dir. Ошибка стабильно продолжает появляться каждый раз. Запись/чтение топиков работают. Так же данная ошибка замечена в KSQL при создании аггрегаций в TABLE.
Обсуждают сегодня