1、下载地址：
https://mirrors.bfsu.edu.cn/apache/kafka/2.5.0/kafka_2.13-2.5.0.tgz
2、下载后，解压：tar -zxvf kafkaxxxxxx.tgz
3、删除 LICENSE、NOTICE 、site-docs
4、进入bin目录：cd bin
5、启动：
①.启动zookeeper：
nohup ./zookeeper-server-start.sh ../config/zookeeper.properties &
②.启动Kafka：
nohup ./kafka-server-start.sh ../config/server-2.properties &
6、创建topic
./kafka-topics.sh --create --zookeeper Icloud_143:2181 --replication-factor 1 --partitions 1 --topic test
7、查看topic
①查看所有topic
./kafka-topics.sh --list --zookeeper zhangqi:2181
②查看当前创建的topic描述
./kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
8、启动生产者（控制台）
./kafka-console-producer.sh --broker-list zhangqi:9092 --topic test
9、启动消费者（控制台）
./kafka-console-consumer.sh --bootstrap-server zhangqi:9092 --topic test
10、在生产者控制台输入字符串，可以看到消费者控制台进行消费并打印。
11、也可以一次性消费之前所有的消息：
./kafka-console-consumer.sh --bootstrap-server zhangqi:9092 --topic test --from-beginning