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

    第一种方式:

    1.修改server.properties文件

    delete.topic.enable=true

    auto.create.topics.enable=false

    2.确保所有的生产者,消费者都已经停掉

    3.执行bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic demo

    4.执行bin/kafka-topics.sh --list --zookeeper localhost:2181

    第二种方式:手工删除

    1.在server.properties文件中配置的logs.dir路径中执行rm -rf demo*,将文件全部删除

    2.在zookeeper中客户端中,使用./zkCli.sh

    [zk: localhost:2181(CONNECTED) 0] ls /brokers/topics
    [__consumer_offsets, demo, test]
    [zk: localhost:2181(CONNECTED) 1] rmr /brokers/topics/demo
    The command 'rmr' has been deprecated. Please use 'deleteall' instead.
    [zk: localhost:2181(CONNECTED) 2] deleteall /brokers/topics/demo
    Node does not exist: /brokers/topics/demo
    [zk: localhost:2181(CONNECTED) 3] ls /admin/delete_topics/demo
    Node does not exist: /admin/delete_topics/demo

    注意第二种方式可以不用重启kafka与zookeeper

    彻底删除topic:

     1、删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录

      2、如果配置了delete.topic.enable=true直接通过命令删除,如果命令删除不掉,直接通过zookeeper-client 删除掉broker下的topic即可。

      

    s

  • 相关阅读:
    FFC详解及应用
    getBoundingClientRect
    userAgent
    各种排序算法的分析及java实现
    解读TCP 四种定时器
    TCP那些事儿(下)
    TCP那些事儿(上)
    10个实用的 Linux 网络和监控命令[转]
    监控 Linux 性能的 18 个命令行工具[转]
    4个强大的Linux服务器监控工具[转]
  • 原文地址:https://www.cnblogs.com/zf201149/p/11610700.html
Copyright © 2011-2022 走看看