一:注册中心
首先,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安装目录打卡窗口执行&