kafka的Topic(三)

kafka主要有三个模块组成：producer、topic、consumer，每个模块都有对应的指令，作者在封装时对每个模块都封装了对应的脚本。Topic 命令 Topic 命令对应的启动脚本是 kafka-topcis.sh，直接在执行这个脚本可以看到相关的参数。参数太多，整理出一些常用的仅供参考参数描述–bootstrap-server <String: server to con

華小灼

5260人浏览 · 2022-03-20 21:07:52

華小灼 · 2022-03-20 21:07:52 发布

kafka主要有三个模块组成：producer、topic、consumer，每个模块都有对应的指令，作者在封装时对每个模块都封装了对应的脚本。
在这里插入图片描述

Topic 命令

Topic 命令对应的启动脚本是 kafka-topcis.sh，直接在执行这个脚本可以看到相关的参数。参数太多，整理出一些常用的仅供参考

参数	描述
–bootstrap-server <String: server to connect to>	连接的Kafka broker 主机名称和端口
–topic <String: topic>	操作的topic名称
–create	创建主题
–delete	删除主题
–alter	修改主题
–list	查看所有主题
–describe	查看主题详细描述
–partitions <Integer: # of partitions>	设置分区数
–replication-factor <Integer: replication factor>	设置分区副本
–config <String: name=value>	更新系统默认的配置
–if-exists	如果在更改、删除或描述主题时设置，则仅当主题存在时才会执行该操作。
–if-not-exists	如果在创建主题时设置，则仅当主题不存在时才会执行该操作。

接下来就演示这些指令的使用

# 查看kafka的topic
kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list

# 创建topic，并设置分区数和副本数，注意：如果你是集群，副本数值小于等于集群数，单机只能是1
kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --topic first --create --partitions 1 --replication-factor 1

# 查看主题的详细信息
kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --topic first --describe

# 修改主题，注意：分区数只能升不能降
kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --topic first --alter --partitions 3

# 删除主题
kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --topic first --delete