Kafka安装与配置

1，安装JDK并安装，下载Kafka http://kafka.apache.org/downloads

2， 解压Kafka 解压后如下：

      

3，配置zookeeper 配置文件（kafka_2.11-1.0.2\config\zookeeper.properties）

 

将dataDir目录写成本地存在的目录

4，配置kafka配置文件,将log.dirs 修改成本地村在的路径（kafka_2.11-1.0.2\config\server.properties）

  例如：log.dirs=D:/Launch/kafka_2.11-1.0.2/kafka_2.11-1.0.2/kafka-logs

5，接下来依次启动zookeeper,kafka

有的时间会报错提示：

     错误: 找不到或无法加载主类 Files\Java\jdk1.8.0_172\lib;C:\Program

     这个时候修改一下配置文件kafka-fun-class.bat 添加双引号

set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp "%CLASSPATH%" %KAFKA_OPTS% %*

6，执行从规划命令启动完成 

启动zookeeper

.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties 

启动Kafka

.\bin\windows\kafka-server-start.bat .\config\server.properties