kafka主题命令行操作

Posted 2022-04-06 爱上口袋的天空

1、操作主题命令参数

---

2、创建 topic命令

创建一个名为first的主题命令如下：

bin/kafka-topics.sh --bootstrap-server 192.168.56.20:9092 --create --partitions 1 --replication-factor 3 --topic first

 选项说明：
   --topic 定义 topic 名
   --replication-factor 定义副本数
   --partitions 定义分区数

---

3、 查看当前服务器中的所有 topic

命令如下：bin/kafka-topics.sh --bootstrap-server 192.168.56.20:9092 --list

 由上我们可以看到我们上面创建的first主题

---

4、查看 first 主题的详情

命令：

        bin/kafka-topics.sh --bootstrap-server 192.168.56.20:9092 --describe --topic first

---

5、 修改分区数（注意：分区数只能增加，不能减少）

命令：

        bin/kafka-topics.sh --bootstrap-server 192.168.56.20:9092 --alter --topic first --partitions 3

可以发现修改之后已经存在3个分区了 

---

6、删除 topic

命令：

        bin/kafka-topics.sh --bootstrap-server 192.168.56.20:9092 --delete --topic first 由上面可以发现已经删除了