精华内容
下载资源
问答
  • kafka删除topic命令

    2016-04-22 09:09:00
    kafka删除topic命令: kafka-run-class.bat kafka.admin.TopicCommand --delete --zookeeper localhost:2181 --topic test 转载于:https://my.oschina.net/zhaokaiju/blog/664158

    kafka删除topic命令:

    kafka-run-class.bat kafka.admin.TopicCommand --delete --zookeeper localhost:2181 --topic test
    

    转载于:https://my.oschina.net/zhaokaiju/blog/664158

    展开全文
  • 删除topic有一般是两...当前topic有使用过即有过传输过信息:用kafka-topics.bat的delete命令并没有真正删除topic,只是把这个topic标记为删除(marked for deletion) 还需要以下操作: 配置kafka中server....

    要删除的topic有一般是两种状态之一:

    1. 当前topic没有使用过-没有传输过信息:用kafka-topics.bat的delete命令可以彻底删除
    2. 当前topic有使用过即有过传输过信息:用kafka-topics.bat的delete命令并没有真正删除topic,只是把这个topic标记为删除(marked
      for deletion) 还需要以下操作:
    • 配置kafka中server.properties添加:delete.topic.enable=true

    • 删除kafka中的topic

       .\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --delete --topic topic_name
      
    • 手动删除kafka中文件夹logdir下,对应的topic_name文件夹

    • 打开zookeeper的bin文件目录下的zkCli.cmd脚本命令:
      通过输入以下命令,删除以下路径名为topic_name的topic:

         rmr /config/topics/topic_name
        rmr /brokers/topics/topic_name
        rmr /admin/delete_topics/topic_name
      
    • 重启zookeeper和kafka,查看要删除的的topic是否已经删除:

          .\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --list
      
    展开全文
  • Kafka 彻底删除 topic 操作命令流程

    千次阅读 2017-11-22 14:24:12
    如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况 1.如果当前topic没有使用过即没有传输过信息:可以彻底删除 2.如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为...

    如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况

    如果当前topic没有使用过即没有传输过信息:可以彻底删除
    如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为删除(marked for deletion)



    针对第二种情况(以game_log_game_skuld_01这个topic为例)

    1.先确定kafka的server.properties中的,如果是集群,就需要把每台机上的kafka的 delete.topic.enable=true 设为true

    2.断开所有的消费者和生产者

    3.进行删除工作:
    进入kafka/bin:输入删除命令
    /usr/local/kafka/bin/kafka-topics.sh --delete --zookeeper master:2181,slave1:2181,slave2:2181 --topic game_log_game_skuld_01
    #应该会提示:marked for deletion

    4.移除 kafka 数据目录,非必须,慎重操作
    #rm -rf /data/kafka/logs/game_log_game_skuld_01*

    5.进入zookeeper的目录登录zookeeper客户端

    /usr/local/zookeeper/bin/zkCli.sh -server master:2181,slave1:2181,slave2:2181

    #查看这几个文件夹下是否有需要删除的topic的消费组id,有的话也要删除
    ls /config/topics
    ls /consumers
    ls /brokers/topics
    ls /admin/delete_topics

    rmr /xx/xx/game_log_game_skuld_01

    6.查看相关的topic是否存在,不存在删除成功
    /usr/local/kafka/bin/kafka-topics.sh --list --zookeeper master:2181,slave1:2181,slave2:2181


    7.#重启 kafka
    cd /usr/local/kafka
    ./start.sh 

    8#窗口消费 topic
    /usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper master:2181,slave1:2181,slave2:2181 --from-beginning --topic game_log_game_skuld_01

    展开全文
  • 创建topic命令(例:创建topic test) bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-...删除topic命令(例:删除topic test) bin/kafka-topics.sh --delete --zookeeper localhost:2

    创建topic的命令(例:创建topic test)
    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test
    partitions是主题分区数,replication-factor是主题副本数量

    删除topic的命令(例:删除topic test)
    bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

    查看topic的命令
    bin/kafka-topics.sh --zookeeper localhost:2181 --list

    展开全文
  • 命令格式:注意空格 ./kafka-topics.sh --create --topic topic名称--partitions分区数--replication-factor备份数--zookeeperZooKeeper的任意一个节点或者全部的IP:Port/kafka 示例: ./kafka-topics.sh --...
  • kafka topic 命令操作

    千次阅读 2018-03-19 09:56:09
    bin/kafka-topics.sh --list --zookeeper localhost:2181(查看topic)bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topictest --from-beginning(查看topic内数据)bin/kafka-topics.sh --...
  • 查看当前服务器中的所有的topic,创建topic 删除topic 通过shell命令发送消息,通过shell消费消息,
  • 如果只是用kafka-topics.bat的delete命令删除topic,会有两种情况 1.如果当前topic没有使用过即没有传输过信息:可以彻底删除 2.如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为...
  • kafka2:常用topic命令

    2017-01-21 22:46:00
    bin/kafka-topics.sh --create --zookeeper 192.168.3.230:2181 --replication-factor 3 --partitions 1 --topic test-topictopic指定topic name –partitions指定分区数,这个参数需要根据broker数和数据量决定...
  • kafka topic常用命令

    2019-11-29 14:06:12
    创建topic ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 #副本数量 --partitions 1 #分区数量 --topic test1 查看topic ./bin/kafka
  • kafka-topics.sh的delete命令删除topic

    万次阅读 2016-09-18 15:52:53
    如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况: 如果当前topic没有使用过即没有传输过信息:可以彻底删除如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为删除...
  • RocketMQ Topic相关命令

    千次阅读 2019-05-13 13:54:26
    1、分配MQ bin/mqadmin allocateMQ -n localhost:9876 -t tst-topic -i ipList ipList 以逗号分隔 2、删除topic bin/mqadmin deleteTopic -n localhost:9876 -t zto-example ...
  • kafka的topic默认是不允许被删除的,删除后在topic后会出现”marked for deletion”字样,实际并未删除,现在创建同样的topic会提示topic已经存在。 解决办法: server.properties配置文件中添加:delete.topic....
  • Kafka topic常见命令解析本文着重介绍几个常用的topic命令行命令,包括listTopic,createTopic,deleteTopic和describeTopic等。由于alterTopic并不是很常用,本文中就不涉及了。另外本文的代码分析是基于kafka_2.10...
  • 当启动kafka的服务出现Map failed时,...2、Kafka 删除topic命令是: bin/kafka-topics.sh --delete --zookeeper 【zookeeper server(主机ip:2181)】 --topictopic name】 如果kafaka启动时加载的配置文件中s.
  • kafka彻底删除topic及相关数据修改配置删除topic命令删除kafka存储目录删除zookeeper存储信息查看topic是否被删除 修改配置 1、停止要删除topic的生产和消费程序,否则无法删除。同时,需要设置auto.create.topics....
  • kafka的topic常用命令

    2020-04-01 15:34:33
    查看topic列表 ./kafka-topics.sh --zookeeper ip:2181 --list 创建topic ./kafka-topics.sh --zookeeper ip:2181 --create --replication-factor 1 --partitions 8 --...删除topic ./kafka-topics.sh --zookeepe...
  • 一、 Kafka常用操作命令 查看当前服务器中的所有topic[root@hadoop3 kafka]# bin/kafka-topics.sh --list --zookeeper hadoop11:2181 [root@hadoop3 kafka]#信息写入到  创建topic[root@hadoop3 kafka]# bin/...
  • kafka删除topic详解

    2016-09-30 09:50:00
    1.删除topic命令 bin/kafka-topics.sh --delete --zookeeper 192.168.242.131:2181 --topic aaa 注:此命令如果要生效,还需在server.properties中添加: delete.topic.enable=true 控制台也会有返回...
  • kafka部署及实例命令 彻底删除topic

    千次阅读 2015-06-02 15:32:54
    1、安装zookeeper 2、安装kafka Step 1: 下载Kafka ... > tar -xzf kafka_2.10-0.8.2.1.tgz > cd kafka_2.10-0.8.2.1 ...Kafka用到了Zookeeper,所有首先启动Zookper,下面简单的启用一个单实例的...可以在命令的结尾加
  • Kafka删除topic

    千次阅读 2019-09-26 10:28:51
    topic中的元数据存储在ZooKeeper中的/brokers/topics和/config/topics路径下,topic中的消息数据存储在log.dir或log.dirs配置的路径下,所以删除topic就需要删除这些路径下的内容。 准备工作 创建topic: bin/...
  • kafka彻底删除topic

    2018-08-10 14:35:14
    如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况: 如果当前topic没有使用过即没有传输过信息:可以彻底删除 如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为...
  • 查看当前服务器中的所有topic: bin/kafka-topics.sh --zookeeper 主机:2181 --list 创建topic: bin/kafka-topics.sh --zookeeper 主机:2181 --create --replication-factor 3 --...删除topic: bin/kafka-topics....
  • Kafka 删除topic

    2019-03-29 15:38:27
    删除topic里面的数据 这里没有单独的清空数据的命令,这里要达到清空数据的目的只需要以下步骤: 一、如果当前topic没有使用过即没有传输过信息:可以彻底删除。 二、 如果当前topic有使用过即有过传输过信息:并...
  • 创建名称为test2的同topic kafka-topics --create --bootstrap-server localhost:9092 --topic test3 --partitions 10 --replication-...删除名称为test3 的topic 命令如下 kafka-topics --create --bootstrap-server l
  • kafka删除topic

    2018-08-11 14:55:00
    删除已经创建的topic  删除toipc主要使用:kafka-...但是如果server.properties文件中delete.topic.enable设置的值是false(默认false),则这个命令只是对topic进行了标记删除,并没有真正的删除对应的文件,这时需...
  • Kafka Shell基本命令(包括topic的增删改查) 创建kafka topic 查看所有topic列表 查看指定topic信息 控制台向topic生产数据 控制台消费topic的数据 查看topic某分区偏移量最大(小)值 增加topic分区数 ...
  • 大数据_Kafka_kafka-topics.sh 脚本相关的 Topic常用命令

    万次阅读 多人点赞 2016-08-12 12:25:59
    本文着重介绍几个常用的topic命令行命令,包括listTopic,createTopic,deleteTopic和describeTopic等。由于alterTopic并不是很常用,本文中就不涉及了。另外本文的代码分析是基于kafka_2.10-0.8.2.1的(虽然截图是...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 27,845
精华内容 11,138
关键字:

删除topic命令