Невозможно настроить Apache Zookeeper и Kafka на windows машине - PullRequest
0 голосов
/ 15 апреля 2020

Я очень новичок в 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

И Кафка из местоположения: 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.

1 Ответ

0 голосов
/ 16 апреля 2020

Я просмотрел это видео https://www.youtube.com/watch?v=TTsOoQ6_QB0, и это решило мою проблему.

Apache Zookeeper:

Создать zookeeper_data (Вы можете выбрать любое имя) внутри C:\kafka_2.11-2.3.1, где хранился мой дистрибутив Kafka.

Затем go до 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

Apache Kafka: Создайте kafka-logs папку в C:\kafka_2.11-2.3.1, а затем Go в C:\kafka_2.11-2.3.1\config и отредактируйте server.properties файл и использование ниже

enter image description here

# 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-server-start.bat C:\kafka_2.11-2.3.1\config\server.properties

enter image description here

...