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

  • 相关阅读:
    移动端--基于Android Studio的项目文件结构(一)【转】
    java知识体系粗略梳理
    简单的使用hibernate插入数据的例子
    触发器
    存储过程和函数
    视图
    索引的设计和使用
    数据类型的选择
    表类型(存储引擎)的选择
    MySQL中的常用函数
  • 原文地址:https://www.cnblogs.com/zf201149/p/11610700.html
Copyright © 2011-2022 走看看