zoukankan      html  css  js  c++  java
  • kafka 删除topic

    两种方法:

    一、修改配置文件server.properties

        添加如下配置:

            delete.topic.enable=true

    说明:官方给的文档说明“Enables delete topic. Delete topic through the admin tool will have no effect if this config is turned off”,意思就是说如果想删除topic,此项配置必须为true,默认为false。配置完重启kafka、zookeeper。

    二、如果不想修改配置,也可以彻底删除topic

    1、删除kafka存储目录(server.propertiewenjian log.dirs配置,默认为“/tmp/kafka-logs”)下对应的topic。(不同broker下存储的topic不一定相同,所有broker都要看一下)

    2、进入zookeeper客户端删掉对应topic

            zkCli.sh  -server 127.0.0.1:42182

       找到topic目录

            ls   /brokers/topics

       删掉对应topic

        rmr  /brokers/topic/topic-name

       找到目录

            ls    /config/topics

       删掉对应topic

            rmr  /config/topics/topic-name  

    以上两步全部执行才算彻底删除topic
    ---------------------
    作者:桃花惜春风
    来源:CSDN
    原文:https://blog.csdn.net/xiaoyu_bd/article/details/52268647
    版权声明:本文为博主原创文章,转载请附上博文链接!

  • 相关阅读:
    CBV进阶(一)
    uva 11748 Rigging Elections
    uva 11573 Ocean Currents(bfs+优先队列)
    无向图的欧拉路
    poj 3254 Corn Fields
    hdu 1114
    hdu 2639 (第k小的01背包)
    uva 1347 tour
    uva 437 The Tower of Babylon
    uva 1025 A Spy in the Metro(动态规划)
  • 原文地址:https://www.cnblogs.com/vana/p/10201299.html
Copyright © 2011-2022 走看看