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输入的信息