Удаленная тема Кафки не может быть воссоздана с тем же именем - PullRequest
1 голос
/ 15 марта 2019

Я пометил тему для удаления, и она там навсегда не удалялась (даже если для 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

1 Ответ

0 голосов
/ 15 марта 2019

Итак, я где-то читал, что вам следует перезапустить брокеров, и это может решить эту проблему.Поэтому я попробовал это и достаточно точно после перезапуска ISR были в правильном состоянии, и тема снова стала пригодной для использования.без перезапуска брокеров, так как в производственной среде я хотел бы избежать этого.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...