Jak usunąć temat w apache kafka [duplikat]

Question

Jak usunąć temat w apache kafka [duplikat]

To pytanie ma już odpowiedź tutaj:

Usuń temat w Kafka 0.8.1.1 12 odpowiedzi

Muszę usunąć temat w kafka-0.8.2.2.3. Do usunięcia tematu użyłem poniższego polecenia:

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

Polecenie wykonane pomyślnie, ale kiedy uruchamiam polecenie, aby wyświetlić listę tematów, widziałem, że temat nadal tam jest i pokazuje oznaczony do usunięcia.

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

I kiedy tworzę temat DummyTopic wyświetla wyjątek, temat już istnieje, poniżej jest ślad stosu:

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)

Proszę dać mi znać, jak mogę usunąć ten temat.

42

java apache-kafka hadoop

Author: Eric Leschinski, 2015-11-05

Source

1 answers

score 52 · Accepted Answer

Usuwanie tematu jest obsługiwane od wersji 0.8.2.wersja X. Musisz najpierw włączyć usuwanie tematu (ustawienie delete.topic.enable Na true) u wszystkich brokerów.

Uwaga: Od 1.0.x, funkcjonalność jest stabilna, {[0] } jest domyślnie true.

Wykonaj ten krok po kroku proces ręcznego usuwania tematów

Stop Kafka Serwer
Usuń katalog tematyczny za pomocą polecenia rm -rf
Połącz się z instancją Zookeeper : zookeeper-shell.sh host:port
ls /brokers/topics
Usuń folder tematyczny z ZooKeeper za pomocą rmr /brokers/topics/yourtopic
Restart Kafka Serwer
Potwierdź, czy został usunięty, używając tego polecenia kafka-topics.sh --list --zookeeper host:port