1. 安装jdk;

2. 下载zookeepe并启动；

下载地址：

https://archive.apache.org/dist/zookeeper/zookeeper-3.5.8/apache-zookeeper-3.5.8-bin.tar.gz

将conf目录下的zoo_sample.cfg复制一份重命名为zoo.cfg。

启动：

3. 下载kafka并启动；

下载地址：

https://archive.apache.org/dist/kafka/2.4.1/kafka_2.11-2.4.1.tgz

修改server.properties配置文件

启动：

4. 创建一个topic;

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic myTopicName

查看topic

kafka-topics.bat --list --zookeeper localhost:2181

5. 创建生产者

kafka-console-producer.bat --broker-list localhost:9092 --topic myTopicName

6. 创建消费者

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic myTopicName

待解决：第四条消息，中文乱码了