kafka的安装使用

  • Post author:
  • Post category:其他


一:注册中心

首先,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安装目录打卡窗口执行&



版权声明:本文为universeXia原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。