kafka主要有三个模块组成：producer、topic、consumer，每个模块都有对应的指令，作者在封装时对每个模块都封装了对应的脚本。
Topic 命令
Topic 命令对应的启动脚本是 kafka-topcis.sh，直接在执行这个脚本可以看到相关的参数。参数太多，整理出一些常用的仅供参考
| 参数 | 描述 |
|---|---|
| –bootstrap-server | 连接的Kafka broker 主机名称和端口 |
| –topic | 操作的topic名称 |
| –create | 创建主题 |
| –delete | 删除主题 |
| –alter | 修改主题 |
| –list | 查看所有主题 |
| –describe | 查看主题详细描述 |
| –partitions | 设置分区数 |
| –replication-factor | 设置分区副本 |
| –config | 更新系统默认的配置 |
| –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
