精华内容
下载资源
问答
  • kafka删除topic命令
    千次阅读
    2022-06-09 19:45:05

    以下删除kafka主题的方法在Windows环境下测试通过:

    首先修改kafka的配置文件server.properites,修改下面的两个值:

    auto.create.topics.enable=false
    delete.topic.enable=true

    如果没有,直接增加上面的两行。重启kafka。

    然后在kafka目录下执行下面的操作:

    .\bin\windows\kafka-topics.bat --delete --zookeeper localhost:2181 --topic TopicName

    在文件目录下查看对应主题的目录是否删除,如果没有删除则手动删除。文件目录在配置文件server.properites中的log.dirs处查找。

    至此,topic删除完毕,如果之前有连接的生产者和消费者,此时会显示找不到相应的主题。

    [Consumer clientId=consumer-1, groupId=javagroup] Error while fetching metadata with correlation id 4837 : {TopicName=UNKNOWN_TOPIC_OR_PARTITION}

    更多相关内容
  • 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

    展开全文
  • Kafka删除topic

    万次阅读 2021-03-07 13:57:02
    2、Kafka 删除topic命令是: ./bin/kafka-topics --delete --zookeeper 【zookeeper server】 --topictopic name】 如果kafaka启动时加载的配置文件中server.properties没有配置delete.topic.enabl

    彻底删除Kafka中的topic

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

    2、Kafka 删除topic的命令是:

     ./bin/kafka-topics  --delete --zookeeper 【zookeeper server】  --topic 【topic name】
    
     如果kafaka启动时加载的配置文件中server.properties没有配置delete.topic.enable=true,那么此时的删除并不是真正的删除,而是把topic标记为:marked for deletion
    
     你可以通过命令:./bin/kafka-topics --zookeeper 【zookeeper server】 --list 来查看所有topic
    
    
    
     此时你若想真正删除它,可以如下操作:
    
     (1)登录zookeeper客户端:命令:./bin/zookeeper-client
    
     (2)找到topic所在的目录:ls /brokers/topics
    
     (3)找到要删除的topic,执行命令:rmr /brokers/topics/【topic name】即可,此时topic被彻底删除。
    
    
    
    另外被标记为marked for deletion的topic你可以在zookeeper客户端中通过命令获得:ls /admin/delete_topics/【topic name】,
    
    如果你删除了此处的topic,那么marked for deletion 标记消失
    
    zookeeper 的config中也有有关topic的信息: ls /config/topics/【topic name】暂时不知道有什么用
    

    总结:

    彻底删除topic:

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

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

    展开全文
  • 删除Topic1.3.Topic分区扩容1.4.查询Topic描述1.5 查询Topic列表 1.TopicCommand 1.1.Topic创建 bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 3 --topic ...

    1.TopicCommand

    1.1.Topic创建

    bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 3 --topic test
    

    相关可选参数:

    在这里插入图片描述

    1.2.删除Topic

    bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic test
    

    支持正则表达式匹配Topic来进行删除,只需要将topic 用双引号包裹起来 例如: 删除以create_topic_byhand_zk为开头的topic;

    bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic "create_topic_byhand_zk.*" 
    

    .表示任意匹配除换行符 \n 之外的任何单字符。要匹配 . ,请使用 . 。·*·:匹配前面的子表达式零次或多次。要匹配 * 字符,请使用 。. : 任意字符

    删除任意Topic

    bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic ".*?"
    

    1.3.Topic分区扩容

    分区只可以扩容不可以缩容

    副本不可以通过命令行改变,

    zk方式(不推荐)

    bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic1 --partitions 2
    

    kafka版本 >= 2.2 支持下面方式(推荐)

    单个Topic扩容

    bin/kafka-topics.sh --bootstrap-server broker_host:port --alter --topic test_create_topic1 --partitions 4
    

    批量扩容 (将所有正则表达式匹配到的Topic分区扩容到4个)

    sh bin/kafka-topics.sh --topic ".*?" --bootstrap-server 172.23.248.85:9092 --alter --partitions 4
    

    当某个Topic的分区少于指定的分区数时候,他会抛出异常;但是不会影响其他Topic正常进行;

    参数说明:

    在这里插入图片描述
    虽然这里配置的是全部的分区副本分配配置,但是正在生效的是新增的分区; 比如: 以前3分区1副本是这样的

    在这里插入图片描述
    现在新增一个分区,–replica-assignment 2,1,3,4 ; 看这个意思好像是把0,1号分区互相换个Broker

    在这里插入图片描述
    但是实际上不会这样做,Controller在处理的时候会把前面3个截掉; 只取新增的分区分配方式,原来的还是不会变

    在这里插入图片描述

    1.4.查询Topic描述

    1.查询单个Topic

    sh bin/kafka-topics.sh --topic test --bootstrap-server xxxx:9092 --describe --exclude-internal
    

    2.批量查询Topic(正则表达式匹配,下面是查询所有Topic)

    sh bin/kafka-topics.sh --topic ".*?" --bootstrap-server xxxx:9092 --describe --exclude-internal
    

    支持正则表达式匹配Topic,只需要将topic 用双引号包裹起来

    参数说明:

    在这里插入图片描述

    1.5 查询Topic列表

    1.查询所有Topic列表

    sh bin/kafka-topics.sh --bootstrap-server xxxxxx:9092 --list --exclude-internal
    

    2.查询匹配Topic列表(正则表达式)

    查询test_create_开头的所有Topic列表 sh bin/kafka-topics.sh --bootstrap-server xxxxxx:9092 --list --exclude-internal --topic "test_create_.*"
    

    在这里插入图片描述

    展开全文
  • kafkatopic管理常用命令

    千次阅读 2021-08-09 15:06:06
    1.查看 Topic 列表 bin/kafka-topics.sh --list --...bin/kafka-topics.sh --describe --bootstrap-server node1:9092,node2:9092,node3:9092 --topic topicName 3.创建 Topic bin/kafka-topics.sh --create --bo
  • kafka彻底删除topic

    千次阅读 2022-05-16 10:27:59
    Kafka如何彻底删除topic及数据 前言: 删除kafka topic及其数据,严格来说并不是很难的操作。但是,往往给kafka 使用者带来诸多问题。项目组之前接触过多个开发者,发现都会偶然出现无法彻底删除kafka的情况。本文...
  • kafka删除topic方式

    千次阅读 2019-11-18 14:38:28
    工作中因为各种原因,topic中消息堆积的太多或者kafka所在磁盘空间满了等。可能需要彻底清理一下kafka topic。 cd /opt/kafka/kafka_2.10-0.10.2.2/bin 列出所有topic: ./kafka-topics.sh --zookeeper ip:2181 -list...
  • ./kafka-configs.sh --zookeeper 10.106.176.71:2181 --entity-type topics --entity-name rs_ods_my_sp_gradeandweight_si --alter --add-config retention.ms=10000
  • Kafka如何彻底删除topic及数据

    千次阅读 2021-07-06 08:57:00
    调用kafka delete命令则无法删除topic。取消自动闯将topic,设置 auto.create.topics.enable = false。 2、server.properties 设置 delete.topic.enable=true,否则调用kafka 的delete命令无.
  • kafka删除topic,彻底删除topic

    千次阅读 2021-07-13 19:01:09
    当启动kafka的服务出现Map failed时,...2、Kafka 删除topic命令是: bin/kafka-topics.sh --delete --zookeeper 【zookeeper server(主机ip:2181)】 --topictopic name】 如果kafaka启动时加载的配置文件中s.
  • ./kafka-topics.sh --create --topic topic名称--partitions分区数--replication-factor备份数--zookeeperZooKeeper的任意一个节点或者全部的IP:Port/kafka 示例: ./kafka-topics.sh --zookeeper 192.168.61.102...
  • kafka创建topic、添加配置等相关操作

    千次阅读 2022-06-28 09:56:15
    创建topickafka命令行消费者、kafka命令行生产者、删除topickafka单个topic增加配置。 kafka-console-consumer、kafka-console-producer、kafka-topics、kafka-configs的使用
  • kafka 删除topic 不成功

    2022-01-03 09:32:05
    利用kafka命令删除topic不成功。 kafka-topics.sh --zookeeper hadoop111:2181 --delete --topic test 原因&解决方式1. 配置文件未将delete.topic.enable=true,导致删除命令未及时生效;解决方式:第一种:找到...
  • 2、常用命令 2.1、查看Kafka 版本 $ kafka-topics --version 2.2、创建 topics $ kafka-topics --create --bootstrap-server ky-node1:9092 --replication-factor 1 --partitions 1 2.3、描述 topics $ ...
  • 本文中的操作均基于kafka_1.3.3.0,且所有命令经过实际验证。 2|0常用工具 新建Topic ./kafka-topics --zookeeper 166.188.xx.xx --create --topic flink_source --partitions 1 --replication-factor 1 ...
  • 创建名称为test2的同topic kafka-topics --create --bootstrap-server localhost:9092 --topic test3 --partitions 10 --replication-...删除名称为test3 的topic 命令如下 kafka-topics --create --bootstrap-server l
  • kafka中的topic如何删除

    2020-11-20 10:06:51
    2、Kafka 删除topic命令是: ./bin/kafka-topics --delete --zookeeper 【zookeeper server】 --topictopic name】 如果kafaka启动时加载的配置文件中server.properties没有配置delete.topic.enabl
  • 创建 topic ./kafka-topics.sh --create -zookeeper ****:2181 --topic ...-max-messages 1 --from-beginning 删除topic ./kafka-topics.sh --delete -zookeeper ****:2181 --topic p13_anomaly_detection_topic
  • kafka基础操作命令 kafka 启动 停止 topic 创建,删除 ,设置日志存储时间命令
  • 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时,对于kafka创建topic命令甚是疑惑,有的资料创建topic命令中有的用的是bootstrap.server 有的用的是zookeeper 。也没有说是什么原因,k刚开始搞不懂zookeeper 和bootstrap.server 有什么不同。其实很...
  • kafka删除topic数据

    千次阅读 2021-11-14 20:30:12
    kafka删除topic数据 一、概述 生产环境中,有一个topic的数据量非常大。这些数据不是非常重要,需要定期清理。 要求:默认保持24小时,某些topic 需要保留2小时或者6小时 二、清除方式 主要有3个: 1. 基于时间...
  • KafkaTopic 命令
  • 创建topic命令(例:创建topic test) bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-...删除topic命令(例:删除topic test) bin/kafka-topics.sh --delete --zookeeper localhost:2
  • 源码解析kafka删除topic

    千次阅读 2022-03-14 15:25:03
    一,如何删除一个topic 删除一个topic有两个关键点: 1,配置删除参数 delete.topic.enable这个Broker参数配置为True。 2,执行 bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_...
  • Kafka如何删除topic

    2021-11-17 14:53:38
    概述  在平时对kafka...
  • kafka 删除topic 操作指南 删除topic 有两种方式: 开启Kafka的delete.topic.enable=true配置(推荐使用) 手动删除Zookeeper相关数据 方式一 优点:由Kafka来完成Topic的相关删除,只需要修改server.properties...
  • kafka 删除topic清空数据

    千次阅读 2020-04-20 09:13:06
    一般情况下,是不会删除数据的。到达一定时间后,kafka会自动删除。如果一定要删除可以删除topic在重建topic了 No.... 如果需要被删除topic 此时正在被程序 produce和consume...调用kafka delete命令则无法删除该topi...
  • kafka删除topic消息的四种方式

    万次阅读 2021-01-25 09:53:02
    2.执行命令bin/kafka-topics.sh --delete --topic test --zookeeper zk:2181或者使用kafka-manager集群管理工具删除 注意:如果kafka启动之前没有配置delete.topic.enable=true,topic只会标记

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 14,625
精华内容 5,850
关键字:

kafka删除topic命令