我正在使用Confluent(http://www.confluent.io/product/kafka-streams/)的kafka流下载。
我按照说明在Windows上运行Zookeeper和Kafka。但是当我尝试使用命令D:\Softwares\confluent-3.0.1\bin\windows>zookeeper-server-start.bat ./etc/kafka/zookeeper.properties
启动ZooKeeper时,我收到错误
D:\ Softwares \ confluent-3.0.1 \ bin \ windows ../../ etc / kafka / log4j.properties此时出乎意料。
如果我检查“zookeeper-server-start.bat”文件,命令看起来没问题,如下所示。目录confluent-3.0.1 \ etc \ kafka下也存在log4j.properties文件
IF [%1] EQU [] (
echo USAGE: %0 zookeeper.properties
EXIT /B 1
)
SetLocal
IF ["%KAFKA_LOG4J_OPTS%"] EQU [""] (
if exists %~dp0../../etc/kafka/log4j.properties (
set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%~dp0../../etc/kafka/log4j.properties
) else (
set KAFKA_LOG4J_OPTS=-Dlog4j.configuration=file:%~dp0../../config/log4j.properties
)
)
IF ["%KAFKA_HEAP_OPTS%"] EQU [""] (
set KAFKA_HEAP_OPTS=-Xmx512M -Xms512M
)
%~dp0kafka-run-class.bat org.apache.zookeeper.server.quorum.QuorumPeerMain %*
EndLocal
https://github.com/renukaradhya/confluentplatform
以上GIT仓库包含修改后的Windows批处理脚本。
当我在C:\Program Files (x86)
下载kafka下载发行版时,我遇到了同样的错误。移动kafka下载分发到其他驱动器,然后c驱动器为我工作。
查找以下工作命令:D:\kafka_2.12-2.2.0\kafka_2.12-2.2.0>bin\windows\zookeeper-server-start.bat
config / zookeeper.properties
Kafka是从它的官方网站下载的:
https://kafka.apache.org/quickstart