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.
- Detener el servidor de Kafka
-
Elimine el directorio de temas, en cada
intermediario
(como se define en las propiedades
logs.dirs
ylog.dir
) con el comandorm -rf
-
Conéctese a la instancia de
Zookeeper
:
zookeeper-shell.sh host:port
-
Desde la instancia de
Zookeeper
:
-
Liste los temas usando:
ls /brokers/topics
-
Elimine la carpeta de temas de
ZooKeeper
usando:
rmr /brokers/topics/yourtopic
- Salga de la instancia de Zookeeper (Ctrl + C)
-
Liste los temas usando:
- Reinicie el servidor Kafka
-
Confirme si se eliminó o no utilizando este comando
kafka-topics.sh --list --zookeeper host:port
Esta pregunta ya tiene una respuesta aquí:
- Eliminar tema en Kafka 0.8.1.1 14 respuestas
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.