记录常用的kafka常用的topic相关命令 查看topic列表 创建topic --create：创建命令； --topic：后面指定topic名称； --replication-factor：后面指定副本数； --partitions：指定分区数，根据broker的数量决定 ...

.enable没有配置为True，上述命令无效。 修改过期时间： 查询topic offset ...

手动： 删除kafka存储目录（server.properties文件log.dirs配置，默认为"/tmp/kafka-logs"）相关topic目录 删除zookeeper "/brokers/topics/"目录下相关topic节点 命令+手动 ...

概述 　　在平时对kafka的运维工作中，我们经常会由于某些原因去删除一个topic，比如这个topic是测试用的，生产环境中需要删除。或者我想扩容topic的同时，这个topic中的数据我不想要了，这时候删除topic，增加broker，再重新创建topic就会是比较简单的方法。但是kafka ...

执行 windows 脚本 命令行程序，获取 broker 元数据，计算副本分配方案，然后把 topic 的信息写入 zk KafkaController 监听 zk 节点的变化，并产生 TopicChange 事件 ...

一、概述 生产环境中，有一个topic的数据量非常大。这些数据不是非常重要，需要定期清理。 要求：默认保持24小时，某些topic 需要保留2小时或者6小时 二、清除方式 主要有3个： 1. 基于时间 2. 基于日志大小 3. 基于日志起始偏移量 详情，请参考链接 ...

------------恢复内容开始------------ 最近测试环境的kafkaTopic太多太乱，大部分测试用的topic已经没有用了，就想着删掉。查阅了网上博客资料之后进行了操作。 1.有说在kafka的server配置文件中加上delete.topic.enable=true ...

前言 利用kafka命令删除topic不成功。 原因&解决方式 1. 配置文件未将delete.topic.enable=true，导致删除命令未及时生效； 解决方式： 第一种： 找到conf目录下server.properties配置文件，修改 ...