После перезагрузки тема КАФКА, похоже, теряется

Question

Установив KAFKA и просмотрев эти сообщения:

1. Кафка теряет все темы при перезагрузке
2. Тема Кафки больше не существует после перезапуска

и, таким образом, перемещая kafka-logs в / opt ... location, я все же замечаю, что при перезагрузке:

1. я могу воссоздать темуснова.
2. каталог kafka-logs содержит информацию по темам, смещениям и т. д., но он поврежден.

Мне интересно, как это исправить.

Тестированиеновых тем до перезагрузки работает нормально.

Answer 1

В этой виртуальной машине я заметил, что журнал Zookeeper был определен для / tmp.Изменил это на / opt (хотя предположим, что это должен быть / var), и очистка данных Kafka при завершении экземпляра была исправлена.Не уверен, как это объяснить полностью.

Answer 2

Возможны две потенциальные проблемы

1. Если в Docker запущена программа kafka, то перезапуск образа Docker всегда очищает предыдущее состояние и создает новый кластер, поэтому все темы теряются.

2. Проверьте путь данных log.dir или Zookeeper.Если любой из них установлен в каталог / tmp, он будет очищаться при каждой перезагрузке.Следовательно, вы потеряете все логи и темы будут потеряны.