kafka安装 部署 启动(windows环境)

=安装部署= 解压zookeeper-3.4.13.tar.gz 到路径:D:Program Files *定位路径:D:Program Fileszookeeper-3.4.13 创建文件夹 tmpzookeeper *定位路径:D:Program Fileszookeeper-3.4.13conf 复制zoo_sample.cfg文件 命名zoo.cfg 打开zoo.cfg 修改 dataDir=D:Program Fileszookeeper-3.4.13 mpzookeeper clientPort=2181

解压kafka_2.12-2.1.0.tgz 到路径:D: *定位路径:D:kafka_2.12-2.1.0 创建文件夹 tmp 再创建tmp文件夹的子文件夹 kafka_logs *定位路径:D:kafka_2.12-2.1.0config 打开server.properties 修改 log.dirs=D:kafka_2.12-2.1.0 mpkafka-logs

添加 系统环境变量 ZOOKEEPER_HOME D:Program Fileszookeeper-3.4.13

修改 系统环境变量 Path %ZOOKEEPER_HOME%in

=启动= ----------zookeeper【使用】启动:-------- cmd zkServer

---------kafka 【使用】启动:-------- D:kafka_2.12-2.1.0 -》cmd .inwindowskafka-server-start.bat .configserver.properties

=bug= 《1-------- bug: kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING

-》D:kafka_2.12-2.1.0config->server.properties-> zookeeper.connection.timeout.ms=6000000 --------》

《2-------- bug: 找不到或无法加载主类 FilesJavajdk1.8.0_311lib;D:Program

解决第1步: 环境变量 CLASSPATH .;%JAVA_HOME%lib;%JAVA_HOME%lib ools.jar 改 .;%JAVA_HOME%libdt.jar;%JAVA_HOME%lib ools.jar; 解决第2步: 定位:D:kafka_2.12-2.1.0inwindows kafka-run-class.bat 改前 set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp %CLASSPATH% %KAFKA_OPTS% %* 改后 set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp “%CLASSPATH%” %KAFKA_OPTS% %* --------》

解决: props.put(“mail.smtp.ssl.protocols”, “TLSv1.2”); --------》

启动报错:删除logs和tmp文件夹

经验分享 程序员 微信小程序 职场和发展