一、下载安装

到 Kafka 官网下载：https://kafka.apache.org/downloads
https://downloads.apache.org/kafka/

下载好 tar包 后，执行下面命令解压：

tar -zxvf kafka_2.11-2.1.0.tar

二、启动 Zookeeper

进入Zookeeper的 bin目录，执行如下命令：

bin/zkServer.sh start

执行结果：

三、启动

bin/kafka-server-start.sh ./config/server.properties &

四、关闭

bin/kafka-server-stop.sh 

五、启动生产者

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

六、运行 consumer

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

注意 出现错误：
zookeeper is not a recognized option zookeeper参数不支持

解决办法：

1.继续使用新版本

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

2.Kafka更换成老版本，并使用 --zookeeper

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning