栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

windows系统搭建kafka+flume环境

windows系统搭建kafka+flume环境

1.配置环境变量
新建ZOOKEEPER_HOME=G:bigdatatoolzookeeper-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”
.binwindowskafka-server-start.bat .configserver.properties

5.打开新的cmd命令窗口,在kafka的binwindows目录下创建topic执行

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

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

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的binwindows目录下打开新的cmd,执行命令
kafka-console-consumer.bat  --bootstrap-server localhost:9092 --topic topic1 --from-beginning
9.测试在kafka消费者能看到从flume输入的信息

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/773796.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号