标签：localhost cto 补充 sample cal 环境 host kafka nec
kafka是很流行的一款消息队列和流处理组件，其生态非常丰富，今天只简单介绍一下它的安装。
kafka高度依赖于Zookeeper做集群协调和分布式存储，当然kafka社区正在逐渐去掉对Zookeeper的依赖，不过至今你还是需要Zookeeper。
下载清华镜像：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/
解压
conf文件夹下的zoo_sample.cfg是供你参考的示例配置文件，zookeeper启动时会读取名为zoo.cfg的配置文件。如果你只需要一个单节点，可以修改zoo_sample.cfg名称为zoo.cfg，并简单配置如下：
tickTime=2000 initLimit=10 syncLimit=5 dataDir=E:/tmp/zookeeper clientPort=2181
在zookeeper根目录，执行命令 .\bin\zkServer.cmd 启动zookeeper。
补充：将zk注册成windows服务
下载工具：http://archive.apache.org/dist/commons/daemon/binaries/windows/
将 prunmgr.exe、prunsrv.exe拷贝到zk\bin目录下
在zk\bin目录下新建install.bat文件，内容如下：
prunsrv.exe "//IS//%ZOOKEEPER_SERVICE%" ^ --DisplayName="Zookeeper (%ZOOKEEPER_SERVICE%)" ^ --Description="Zookeeper (%ZOOKEEPER_SERVICE%)" ^ --Startup=auto --StartMode=exe ^ --StartPath=%ZOOKEEPER_HOME% ^ --StartImage=%ZOOKEEPER_HOME%\bin\zkServer.cmd ^ --StopPath=%ZOOKEEPER_HOME%\ ^ --StopImage=%ZOOKEEPER_HOME%\bin\zkServerStop.cmd ^ --StopMode=exe --StopTimeout=5 ^ --LogPath=%ZOOKEEPER_HOME% --LogPrefix=zookeeper-wrapper ^ --PidFile=zookeeper.pid --LogLevel=Info --StdOutput=auto --StdError=auto
在zk\bin新建zkServerStop.cmd文件，内容如下：
@echo off setlocal TASKLIST /svc | findstr /c:"%ZOOKEEPER_SERVICE%" > %ZOOKEEPER_HOME%\zookeeper_svc.pid FOR /F "tokens=2 delims= " %%G IN (%ZOOKEEPER_HOME%\zookeeper_svc.pid) DO ( @set zkPID=%%G ) taskkill /PID %zkPID% /T /F del %ZOOKEEPER_HOME%/zookeeper_svc.pid endlocal
新建windows环境变量
ZOOKEEPER_HOME：zk根目录
ZOOKEEPER_SERVICE：zkServer(服务名)
安装成功后可以用zkCli.cmd检测是否可以链接上zkServer
下载清华镜像：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/
解压
config文件夹下的server.properties文件是kafka-server的配置文件，启动是会读取其中的配置。如果你只需要一个单机节点，可以简单配置如下：
broker.id=0 num.network.threads=3 num.io.threads=8 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 log.dirs=E:/tmp/kafka/data/logs num.partitions=1 num.recovery.threads.per.data.dir=1 offsets.topic.replication.factor=1 transaction.state.log.replication.factor=1 transaction.state.log.min.isr=1 log.retention.hours=168 log.segment.bytes=1073741824 log.retention.check.interval.ms=300000 zookeeper.connect=localhost:2181 zookeeper.connection.timeout.ms=18000 group.initial.rebalance.delay.ms=0
在kafka根目录，执行命令 .\bin\kafka-server-start.bat .\config\server.properties 启动kafka。
标签：localhost cto 补充 sample cal 环境 host kafka nec
原文地址：https://www.cnblogs.com/LTEF/p/13614195.html
