1、安装和解压，进入usr/local目录：
# 进入local目录 cd /usr/local/ # 下载kafka wget https://archive.apache.org/dist/kafka/2.5.0/kafka_2.13-2.5.0.tgz # 先重命名在解压 mv kafka_2.13-2.5.0.tgz kafka tar zxvf kafka_2.13-2.5.0.tgz
2、打开一个新窗口，在kafka目录下启动Zookeeper服务器（运行kafka需要使用Zookeeper，所以需要先启动一个Zookeeper服务器，可以使用kafka自带打包和配置好的Zookeeper) ：
cd /usr/local/kafka bin/kafka-server-start.sh config/server.properties &
3、启动kafka服务，打开一个新窗口，运行下面命令：
cd /usr/local/kafka bin/kafka-server-start.sh config/server.properties &4、创建主题， 打开一个新窗口，运行下面命令：
cd /usr/local/kafka # 创建一个名为“test”的Topic，只有一个分区和一个备份 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test # 可以通过以下命令查看已创建的topic信息: bin/kafka-topics.sh --list --zookeeper localhost:2181 test
5、发送消息：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
6、消费消息，打开一个新窗口，运行下面命令：
/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic MyTopic --from-beginning运行测试： 第5步时会有输入框：随意输入 第6步时就会有响应内容响应
