La Confusion à propos de supprimer Kafka Sujet

Je suis l'aide de Kafka 0.8.0, c'est Cloudera version.
Quand j'ai supprimé le sujet, telles que: kafka-topics --zookeeper 10.0.0.11:2181/--delete --topic test
c'réponse:

Topic test is already marked for deletion.

Mais par la suite, j'ai recréé, il jeter l'exception de la manière suivante:

kafka-topics --create --zookeeper 10.0.0.11:2181 --partitions 90 --replication-factor 2 --topic test

Error while executing topic command Topic "test" already exists.
kafka.common.TopicExistsException: Topic "test" already exists.

Des idées s'il vous plaît? Comment dois-je supprimer le sujet et ses données.

Double Possible de Supprimer le sujet dans Kafka 0.8.1.1

OriginalL'auteur Jack | 2016-01-23

  1. 7

    Mon Kakfa version est kafka_2.10-0.8.2.2, ci-dessous le lien fonctionne pour moi (à partir de Supprimer le sujet dans Kafka 0.8.1.1)

    Ajouter la ligne ci-dessous dans ${kafka_home}/config/server.properties 

    delete.topic.enable=true

    Redémarrer l'kafka serveur avec la nouvelle config: 

    ${kafka_home}/bin/kafka-server-start.sh ~/kafka/config/server.properties

    Supprimer les sujets que vous souhaitez:

    ${kafka_home}/bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic daemon12

    Plus d'informations à partir de Kafka FAQ:

    Suppression d'un sujet est pris en charge depuis 0.8.2.x. Vous devez activer le
    sujet supprimer (supprimer.sujet.permettre à true) sur tous les courtiers
    d'abord.

    OriginalL'auteur Shawn Guo

  2. 5
    1. Assurez-vous que, Dans de kafka config.poperties fichier 'supprimer.sujet.activer la propriété doit être vrai.

    2. utiliser la commande ci-dessous

      bin/kafka-topics.sh --delete --zookeeper localhost:2181 --rubrique test

    Même si le sujet n'est pas supprimé, puis suivez les étapes suivantes.

    1. ouvrir un terminal zookeeper en mode client:

      A. arrêter zookeeper

      B. rmr /courtier/topics

      C. vérifiez le sujet donné à l'aide de commande ci-dessous

      /bin/kafka-topics.sh --zookeeper maxiq:2181 --liste

    OriginalL'auteur Balkrushna Patil

  3. 2

    Si delete.topic.enable est à false par défaut, les sujets ne sont pas supprimés lors de l'exécution de --delete de commande (comme indiqué dans la réponse à la commande).

    Topic test is marked for deletion.
Note: This will have no impact if delete.topic.enable is not set to true.

    Afin de surmonter ce problème, utilisez les étapes mentionnées par @Shawn

    OriginalL'auteur daemon12

  4. 1

    Supprimer le sujet dans kafka
    étape 1 -->> lecteur de cd /usr/lib/zookeeper/bin

    étape 2 -->> zkCli.sh -serveur 127.0.0.1:2181

    étape 3 -->>rmr /courtiers/topics/topic_name

    OriginalL'auteur Dhanraj Kumar

  5. 0

    Le meilleur et facile à faire delete.topic.enable=true n'est pas de modifier la server.property fichier.

    Parce que, si kafka redémarrer à partir de ambari, il remplace ce fichier, delete.topic.enable =false de nouveau.

    Seulement à ambari, cliquez sur kafak/config/advance kafka broker/delete.topic.enable =true, il va fonctionner.

    J'ai juste trouvé que comme maintenant.

    OriginalL'auteur Robin