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

kafka的安装使用

kafka的安装使用

一:注册中心
首先,kafka的注册中心是zk,后期版本已经自带,可以不用单独下载zk,直接使用kafka里的就好,如果自己下载部署也行,
zk的下载安装:
下载安装包,解压,复制zoo_sample.cfg文件改名为zoo.cfg;
在解压目录下新建文件夹data,更改刚才复制的zoo文件中的dataDir=data的绝对路径;
启动zk 如果报错 ZooKeeper audit is disabled.
修改zkServer.cmd 中的 call %JAVA% “-Dzookeeper.audit.enable=true” “-Dzookeeper.log.dir=%ZOO_LOG_DIR%” “-Dzookeeper.root.logger=%ZOO_LOG4J_PROP%” “-Dzookeeper.log.file=%ZOO_LOG_FILE%” “-XX:+HeapDumpOnOutOfMemoryError” “-XX:onOutOfMemoryError=cmd /c taskkill /pid %%%%p /t /f” -cp “%CLASSPATH%” %ZOOMAIN% “%ZOOCFG%” %*
启动使用;
如果使用自带的,更改zookeeper.properties里的dataDir路径;
二:kafka的安装
下载kafa
配置:
修改config下的server.properties文件:
修改log地址配置;
根据zookeeper地址进行修改:
启动
先启动zk;
进入kafka安装目录打卡窗口执行:
启动命令:
.binwindowskafka-server-start.bat .configserver.properties
注意:
kafka新版本会有一些bug,找不到log路径,无法写入文件,如果报这个错,首先检查自己配置的log路径中,在启动了kakfa后是否有日志生成,如果没有,先检查自己的路径配置是否正确,如果有,那么更换较低版本kafka即可启动。

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

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

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