twenty tema seventeen resetear quitar pie pagina modificar eliminar desinstalar creado con como java hadoop apache-kafka

java - tema - modificar pie de pagina wordpress 2017



Cómo eliminar un tema en apache kafka (1)

La eliminación de un tema se admite desde la versión 0.8.2.x. delete.topic.enable debe habilitar la eliminación de temas (estableciendo delete.topic.enable en true) en todos los intermediarios.

Nota: Desde 1.0.x, la funcionalidad es estable, delete.topic.enable es por defecto true .

Siga este proceso paso a paso para la eliminación manual de temas.

  1. Detener el servidor de Kafka
  2. Elimine el directorio de temas, en cada intermediario (como se define en las propiedades logs.dirs y log.dir ) con el comando rm -rf
  3. Conéctese a la instancia de Zookeeper : zookeeper-shell.sh host:port
  4. Desde la instancia de Zookeeper :
    1. Liste los temas usando: ls /brokers/topics
    2. Elimine la carpeta de temas de ZooKeeper usando: rmr /brokers/topics/yourtopic
    3. Salga de la instancia de Zookeeper (Ctrl + C)
  5. Reinicie el servidor Kafka
  6. Confirme si se eliminó o no utilizando este comando kafka-topics.sh --list --zookeeper host:port

Esta pregunta ya tiene una respuesta aquí:

Necesito eliminar un tema en kafka-0.8.2.2.3. He utilizado el siguiente comando para eliminar el tema:

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

El comando se ejecutó correctamente, pero cuando ejecuté un comando para enumerar los temas, pude ver que el tema todavía está allí y se muestra marcado para su eliminación .

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

Y cuando creo el tema DummyTopic, genera la excepción. El tema ya existe, a continuación se muestra el seguimiento de la pila:

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)

Avíseme cómo puedo eliminar este tema.