无法在 Windows 机器上设置 Apache Zookeeper 和 Kafka

Question

我对 Apache Zookeeper 和 Kafka 非常陌生。我已经在windows机器上下载了下面。

Apache Zookeeper - http://zookeeper.apache.org/releases.html

卡夫卡-https://kafka.apache.org/downloads.html

我不太清楚接下来要执行什么或在哪里进行必要的更改。

我到C:\apache-zookeeper-3.6.0\bin 执行zkServer.bat文件

C:\apache-zookeeper-3.6.0\bin>call "C:\Program Files\Java\jdk1.8.0_151"\bin\java "-Dzookeeper.log.dir=C:\apache-zookeeper-3.6.0\bin\..\logs" "-Dzookeeper.root.logger=INFO,CONSOLE" "-Dzookeeper.log.file=zookeeper-pc-server-DESKTOP-NQ639DU.log" "-XX:+HeapDumpOnOutOfMemoryError" "-XX:OnOutOfMemoryError=cmd /c taskkill /pid %%p /t /f" -cp "C:\apache-zookeeper-3.6.0\bin\..\build\classes;C:\apache-zookeeper-3.6.0\bin\..\build\lib\*;C:\apache-zookeeper-3.6.0\bin\..\*;C:\apache-zookeeper-3.6.0\bin\..\lib\*;C:\apache-zookeeper-3.6.0\bin\..\conf" org.apache.zookeeper.server.quorum.QuorumPeerMain "C:\apache-zookeeper-3.6.0\bin\..\conf\zoo.cfg"
Error: Could not find or load main class org.apache.zookeeper.server.quorum.QuorumPeerMain

C:\apache-zookeeper-3.6.0\bin>endlocal

和Kafka的位置：C:\kafka_2.11-2.3.1\bin\windows

C:\kafka_2.11-2.3.1\bin\windows>kafka-server-start.bat
USAGE: kafka-server-start.bat server.properties

C:\kafka_2.11-2.3.1\bin\windows>

我已将ZOOKEEPER_HOME=C:\apache-zookeeper-3.6.0 和路径设置为C:\apache-zookeeper-3.6.0/bin。

Answer 1

我浏览了这个视频https://www.youtube.com/watch?v=TTsOoQ6_QB0，它解决了我的问题。

Apache Zookeeper：

在 C:\kafka_2.11-2.3.1 中创建 zookeeper_data（您可以选择任何名称），我的 Kafka 发行版保存在那里。

然后转到C:\kafka_2.11-2.3.1\config并编辑zookeeper.properties文件并使用dataDir=C:\kafka_2.11-2.3.1\zookeeper_data

启动 Zookeeper 的步骤：

zookeeper-server-start.bat C:\kafka_2.11-2.3.1\config\zookeeper.properties

阿帕奇卡夫卡： 在C:\kafka_2.11-2.3.1 下创建kafka-logs 文件夹，然后 转到C:\kafka_2.11-2.3.1\config 并编辑server.properties 文件并在下面使用

# A comma separated list of directories under which to store log files
log.dirs=C:\kafka_2.11-2.3.1\kafka-logs

############################# Internal Topic Settings  #############################
# The replication factor for the group metadata internal topics "__consumer_offsets" and "__transaction_state"
# For anything other than development testing, a value greater than 1 is recommended for to ensure availability such as 3.
offsets.topic.num.partitions=1
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
min.insync.replicas=1
default.replication.factor=1

启动 Apache Kafka 的步骤

kafka-server-start.bat C:\kafka_2.11-2.3.1\config\server.properties