Невозможно запустить Kafka Zookeeper в Windows - PullRequest
Новая
       10

Невозможно запустить Kafka Zookeeper в Windows

0 голосов
/ 05 февраля 2019

Я скачал kafka_2.12-2.1.0 и поместил в путь к папке "C: \ kafka_2.12-2.1.0".Для запуска kafka zookeeper я выполнил приведенную ниже команду в командной строке:

C: \ kafka_2.12-2.1.0> bin \ windows \ zookeeper-server-start.bat config \ zookeeper.properties

Я получаю сообщение об ошибке, как показано ниже,

Синтаксис команды неверен. Имя файла, имя каталога или синтаксис метки томаневерно.

Я не мог понять, что я делаю неправильно.Может кто-нибудь, пожалуйста, помогите.Я успешно могу запустить zookeeper и kafka server в Linux "bin / zookeeper-server-start.sh config / zookeeper.properties"

1 Ответ

0 голосов
/ 05 февраля 2019

Прежде всего, не забывайте, что вы находитесь в операционной системе Windows, поэтому не забывайте точку . перед путем .\bin\...

Установка Zookeeper Найдите свой каталог конфигурации Zookeeper.Например C:\zookeeper-3.4.7\conf.

Найдите .cfg файл и скопируйте и переименуйте zoo_sample.cfg в zoo.cfg в C:\Tools\zookeeper-3.4.9\conf

Откройте его в любом текстовом редакторе, например Блокнот ++

Поиск и редактирование dataDir=/tmp/zookeeper to :\zookeeper-3.4.7\data

Кроме того, добавьте запись в переменные системной среды, как вы это делали для Java.это означает что-то вроде этого 

Add ZOOKEEPER_HOME = C:\zookeeper-3.4.7 to the System Variables.

add ;%ZOOKEEPER_HOME%\bin;

Запустите Zookeeper, открыв новый cmd и введите: zkserver.

KafkaServer

Запуск сервера Kafka типа 

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

Создать тему

, чтобы создать темы сейчас, вы должны сделать это:

  • Теперь создайте тему с именем «test» и коэффициентом репликации 1, поскольку у нас работает только один сервер Kafka.Если у вас есть кластер с несколькими запущенными серверами Kafka, вы можете соответственно увеличить коэффициент репликации, что повысит доступность данных и будет действовать как отказоустойчивая система.

  • Открытьновая командная строка в расположении C: \ kafka_2.12-2.1.0 \ bin \ windows.

  • Введите следующую команду и нажмите Enter: 

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

Создание простого источника и потребителя для тестирования

Откройте новую командную строку в расположении C: \ kafka_2.12-2.1.0 \ bin \ windows и введите это для производителя: 

kafka-console-producer.bat --broker-list localhost:9092 --topic test

Снова откройте новую командную строку в том же месте и введите: 

kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

Посмотрите на это сообщение вы найдете его полезным

...