1.配置环境变量
新建ZOOKEEPER_HOME=G:\bigdatatool\zookeeper-3.4.14
path添加%ZOOKEEPER_HOME%\bin;

2.在zookeeper的conf目录下将zoo_sample.cfg文件重命名为zoo.cfg
3.双击在zookeeper的bin目录下执行zkServer.cmd

4.打开cmd 进入kafka目录，执行以下命令启动kafka
修改server.properties文件里的用#注解“log.dirs=/tmp/kafka-logs”
.\bin\windows\kafka-server-start.bat .\config\server.properties

5.打开新的cmd命令窗口，在kafka的bin\windows目录下创建topic执行

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

6.打开新的cmd命令窗口，在apache-flume-1.8.0-bin\bin目录下执行

flume-ng agent --conf ../conf --conf-file ../conf/example.conf --name a1 -property flume.root.logger=INFO,console

7.打开新的cmd命令窗口，输入
telnet localhost 44444

8.在kafka的bin\windows目录下打开新的cmd，执行命令
kafka-console-consumer.bat  --bootstrap-server localhost:9092 --topic topic1 --from-beginning
9.测试在kafka消费者能看到从flume输入的信息