kafka启动命令：kafka-server-start.sh -daemon (后台运行)
kafka关闭命令：kafka-server-stop.sh
创建topic命令：
kafka-topics.sh --create --bootstrap-server master:2181,slave1:2181,slave2:2181 --topic test1 --partitions 3 --replication-factor 3
修改topic命令：
kafka-topics.sh --alter --bootstrap-server master:2181,slave1:2181,slave2:2181 --topic test1 --partitions 4 (修改分区数，只能增加，不能减少)
查看所有的topic命令：
kafka-topics.sh --list --bootstrap-server master:2181,slave1:2181,slave2:2181
查看某个topic的详细信息命令：
kafka-topics.sh --describe --bootstrap-server master:2181,slave1:2181,slave2:2181 --topic test1
删除topic命令：
kafka-topics.sh --delete --bootstrap-server master:2181,slave1:2181,slave2:2181 --topic test1
生产数据命令：（用于测试）
kafka-console-producer.sh --bootstrap-server master:9092,slave1:9092,slave2:9092 --topic test1
消费数据命令：（用于测试）
kafka-console-consumer.sh --topic test1 --bootstrap-server master:9092,slave1:9092,slave2:9092
可消费到历史数据
kafka-console-consumer.sh --topic test1 --bootstrap-server master:9092,slave1:9092,slave2:9092
--from-beginning