[HADOOP] 아파치 kafka [중복]에서 주제를 삭제하는 방법

아파치 kafka [중복]에서 주제를 삭제하는 방법

kafka-0.8.2.2.3에서 주제를 삭제해야합니다. 주제를 삭제하기 위해 아래 명령을 사용했습니다.

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic DummyTopic

명령이 성공적으로 실행되었지만 주제를 나열하는 명령을 실행할 때 해당 주제가 아직 남아 있고 삭제 표시된 것으로 표시됩니다.

bin/kafka-topics.sh --list --zookeeper localhost:2181
DummyTopic - marked for deletion

그리고 DummyTopic이라는 주제를 만들면 예외가 출력됩니다. 아래에 이미있는 주제가 스택 추적입니다.

Error while executing topic command Topic "DummyTopic" already exists.
kafka.common.TopicExistsException: Topic "DummyTopic" already exists.
    at kafka.admin.AdminUtils$.createOrUpdateTopicPartitionAssignmentPathInZK(AdminUtils.scala:248)
    at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:233)
    at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:92)
    at kafka.admin.TopicCommand$.main(TopicCommand.scala:54)
    at kafka.admin.TopicCommand.main(TopicCommand.scala)

이 주제를 어떻게 삭제할 수 있는지 알려주십시오.

해결법

1. ==============================

   1.주제 삭제는 0.8.2.x 버전 이후로 지원되었습니다. 먼저 모든 브로커에서 주제 삭제 (delete.topic.enable을 true로 설정)를 활성화해야합니다.

   주제 삭제는 0.8.2.x 버전 이후로 지원되었습니다. 먼저 모든 브로커에서 주제 삭제 (delete.topic.enable을 true로 설정)를 활성화해야합니다.

   주 : 1.0.x 이후로, 안정적인 기능인 delete.topic.enable은 기본적으로 true입니다.

   주제를 수동으로 삭제하려면이 단계별 절차를 따르십시오.

from https://stackoverflow.com/questions/33537950/how-to-delete-a-topic-in-apache-kafka by cc-by-sa and MIT license