Kafka之kafka-topics.sh的使用解读

介绍

kafka-topics.sh 是 Kafka 提供的命令行工具，常用于管理 Kafka 的主题。可以使用此工具创建、删除、查看主题信息，以及修改主题的配置等操作。

使用

首先需要进入kafka的bin目录，输入以下命令即可查询所有的命令：

./kafka-topics.sh

查询所有命令接口：

./kafka-topics.sh {-zookeeper <String: zkHost:zkPort>} [options]
                           工具包含以下选项：

    --list                            列出所有的主题列表。
    --zookeeper <String: zkConnect>   Zookeeper 连接字符串，例如 host:port。可以通过多个逗号分开指定。

    --describe                        列出每个主题的详细信息，包括分区，副本数，配置信息，以及已分配的 broker 等。
    --topic <String: topicName>       指定对某一个主题进行操作，例如修改、删除、或者打印所有 topic 级别配置。
    --create                          创建一个新的主题。
    --partitions <Integer: count>     新主题的分区数。
    --replication-factor <Integer: count> 新主题的副本数量。
    --config <name=value>             修改新主题默认配置属性，
    --delete                          删除现有主题。
    --if-exists                       如果主题存在，则进行 topic 删除操作。
    --alter                           修改已有主题。
    --add-config <name=value>         添加 topic 级别的配置信息。
    --delete-config <name>            删除 topic 级别的配置信息。
    --help                            配置详情见 kafka-topis.sh

注意: 以上命令均需附带远程 zookeeper 地址信息，例如

./kafka-topics.sh --list --zookeeper 192.168.0.2:2181

示例1：创建新主题

创建一个名为test及分区数为1的主题

./kafka-topics.sh --create --zookeeper localhost:2181 \ 
--replication-factor 1 --partitions 1 --topic test

参数说明：

--create：创建订阅者
--zookeeper：指定使用的ZooKeeper服务。
--topic：创建主题名称
--partitions：创建该主题的分区数
--replication-factor：消息备份数，默认为1，至少为1。

示例2：列出主题

查询所有的主题

./kafka-topics.sh --zookeeper localhost:2181 --list

参数说明：

--list：列出所有主题