需求描述：lag(滞后）是kafka消费队列性能监控的重要指标，lag的值越大，表示kafka的堆积越严重。本篇文章将使用python脚本+influxdb+grafana的方式对kafka的offset、logsiz和lag这三个参数进行监控，并以图形化的方式进行展现。 架构描述：使用 ...

手动： 删除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配置文件，修改 ...

1，查看kafka topic列表，使用--list参数 2，查看kafka特定topic的详情，使用--topic与--describe参数 列出了lx_test_topic的parition数量、replica因子以及每个partition的leader、replica信息 ...