??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