kafka最好用的脚本四：kafka-log-dirs

kafka-log-dirs 使用手册

官方定义

Option                                  Description
------                                  -----------
--bootstrap-server <String: The server  REQUIRED: the server(s) to use for
  (s) to use for bootstrapping>           bootstrapping

--broker-list <String: Broker list>     The list of brokers to be queried in
                                          the form "0,1,2". All brokers in the
                                          cluster will be queried if no broker
                                          list is specified

--describe                              Describe the specified log directories
                                          on the specified brokers.

--topic-list <String: Topic list>       The list of topics to be queried in
                                          the form "topic1,topic2,topic3". All
                                          topics will be queried if no topic
                                          list is specified (default: )
复制代码

使用方法

选项介绍

--bootstrap-server : 必填项, <broker:port>.

--broker-list : 可选, 可以指定查看某个 broker.id 上 topic-partitions 的size, 不填则默认集群中所有的broker.

--describe : 描述.

--topic-list : 指定要查询的 topic 在disk上的空间占用情况.

复制代码

示例

> ./kafka-log-dirs.sh  --bootstrap-server <broker:port> --describe --broker-list <broker.id_list> --topic-list <topics>
复制代码

作用

可以以此为切入点监控各个 topic-partition 在 disk 上的占用空间情况

结果结构分析

结果返回的json形式，可以参考下面图片:

按照broker.id给出各个 broker 上各个 topic-partition 在 disk 上的占用情况。

每个broker上的情况又按照各个目录下 topic-partition 在 disk 上的占用情况。