Я пометил тему для удаления, и она там навсегда не удалялась (даже если для delete.topic.enable задано значение true). Поэтому я следовал инструкциям и залез в один из зоопарков и запустил следующее, чтобы удалить его:
rmr /brokers/topics/topicname
rmr /admin/delete_topics/topicname
Затем тема, по-видимому, была удалена (не возвращалась при выполнении команды списка). Но потом, когда я попытался воссоздать его с новой конфигурацией (сжатие включено), реплика-синхро-реплики пустые, и я не могу использовать эту тему. Потребление возвращается с ошибками «UNKNOWN_TOPIC_OR_PARTITION», даже если команда list показывает тему как находящуюся там.
Есть ли где-нибудь журнал, на который я могу посмотреть, почему он не может правильно настроить тему после удаления и восстановления? Я пропускаю шаг и неправильно удаляю тему для начала? Почему воссозданная тема не инициализируется должным образом?
То, что я запустил, чтобы удалить тему перед тем, как запустить две вышеупомянутые команды (это оставило тему в 'отмеченной для удаления' на долгое время):
./kafka-topics.sh --zookeeper $KAFKAZKHOSTS --delete --topic topicname
Что я бежал, чтобы воссоздать тему:
/usr/hdp/current/kafka-broker/bin/kafka-topics.sh --create --zookeeper $KAFKAZKHOSTS --replication-factor 3 --partitions 3 --topic topicname --config cleanup.policy=compact
Кафка версия: 1.1.0.2.6.5.3005-27