Apache kafka установка windows

Русские Блоги

Как установить и запустить Apache Kafka в ОС Windows

Ниже приведено пошаговое руководство, которое научит вас устанавливать и запускать Apache Zookeeper и Apache Kafka в ОС Windows.

Введение

В этой статье описывается, как настроить и запустить Apache Kafka в ОС Windows. Это руководство поможет вам установить Java и Apache Zookeeper.
Apache Kafka — это быстрая и масштабируемая очередь сообщений, которая может обрабатывать большие нагрузки чтения и записи, то есть операции, связанные с вводом-выводом. Для получения дополнительной информации см.http://kafka.apache.org. Поскольку Zookeeper может предоставлять надежные службы распределенной координации, Apache Kafka должен запускать экземпляр Zookeeper. Для получения дополнительной информации о Zookeeper, пожалуйста, проверьтеhttps://zookeeper.apache.org/。

Конкретные шаги по установке Kafka в Windows вы можете посмотреть в этом видео:https://youtu.be/OJKesEpO6ok

Скачать необходимые документы

В зависимости от ОС и архитектуры процессора загрузите сервер JRE здесьhttp://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html
Загрузите и установите 7-zip здесьhttp://www.7-zip.org/download.html
Загрузите Zookeeper здесь и разархивируйте его с помощью 7-ziphttp://zookeeper.apache.org/releases.html
Загрузите Kafka здесь и разархивируйте его с помощью 7-ziphttp://kafka.apache.org/downloads.html

В этом руководстве мы извлечем Zookeeper и Kafka на диск C, но вы также можете выбрать другие места. Здесь мы хотим использовать полную версию zookeeper, а не ту, что поставляется с Kafka, потому что это экземпляр Zookeeper с одним узлом. Вы также можете запустить Kafka в пакете с zookeeper, он находится в библиотеке \ kafka \ bin \ windows.

монтаж

A. Установка JDK

1. Запустите установку JRE, установите флажок «Изменить целевой путь» и нажмите «Установить».

2. Измените каталог установки, в имени папки не должно быть пробелов, например: C: \ Java \ jre1.8.0_xx \ (по умолчанию C: \ Program Files \ Java \ jre1.8.0_xx), а затем нажмите Далее.
3. Теперь нажмите «Панель управления» -> «Система» -> «Дополнительные параметры системы» -> «Переменные среды», чтобы открыть диалоговое окно «Переменные системной среды».
4. Нажмите кнопку новой пользовательской переменной в пользовательских переменных, затем введите JAVA_HOME в имя переменной и заполните значение переменной пользовательским путем jre. Как показано ниже:

Путь и версия Java могут меняться в зависимости от используемой версии Kafka.

5. Теперь нажмите ОК.
6. В только что открытом диалоговом окне «Переменные среды» есть столбец «Системные переменные», найдите в нем переменные пути.
7. Измените путь и введите ";% JAVA_HOME% \ bin", как показано ниже:

8. Подтвердите установку Java, откройте cmd, введите «java -version», вы должны увидеть только что установленную версию java.

Если приглашение командной строки похоже на изображение выше, продолжайте. В противном случае необходимо еще раз проверить, соответствует ли установленная версия архитектуре ОС (x86, x64) и правильный ли путь к переменной среды.

Б. Установка Zookeeper

1. Войдите в каталог настроек Zookeeper, например C: \ zookeeper-3.4.7 \ conf
2. Переименуйте "zoo_sample.cfg" в "zoo.cfg".
3. Откройте zoo.cfg в любом текстовом редакторе (например, в блокноте), я лично предпочитаю блокнот ++.
4. Найдите и отредактируйте dataDir = / tmp / zookeeper в: \ zookeeper-3.4.7 \ data.
5. Как и в Java, мы добавляем в системные переменные среды:
а. Добавьте ZOOKEEPER_HOME = C: \ zookeeper-3.4.7 в системные переменные
б. Отредактируйте системную переменную и назовите ее как путь Системная переменная% ZOOKEEPER_HOME% \ bin;
6. Измените порт Zookeeper по умолчанию (порт по умолчанию 2181) в файле zoo.cfg.
7. Откройте новый cmd, введите zkserver и запустите Zookeeper.
8. Приглашение командной строки выглядит следующим образом:

Поздравляем, Zookeeper готов и работает на порту 2181.

В. Установить Kafka

Войдите в каталог конфигурации Kafka, например C: \ kafka_2.11-0.9.0.0 \ config.
Отредактируйте файл server.properties
Найдите и отредактируйте "log.dirs = / tmp / kafka-logs" на "log.dir = C: \ kafka_2.11-0.9.0.0 \ kafka-logs"
Если Zookeeper запущен на другом компьютере или кластере, вы можете изменить "zookeeper.connect: 2181" на собственный IP-адрес и порт. В этой демонстрации мы использовали ту же машину, поэтому нет необходимости изменять ее. Также можно настроить порт Kafka и broker.id в файле. Остальные настройки остаются без изменений.
Kafka по умолчанию будет работать на порту 9092 и подключаться к порту по умолчанию zookeeper: 2181.

D. Запустите сервер Kafka

Важно: перед запуском сервера Kafka убедитесь, что экземпляр Zookeeper готов и работает.

1. Войдите в каталог установки Kafka C: \ kafka_2.11-0.9.0.0 \
2. Нажмите Shift + правая клавиша, выберите параметр «Открыть окно команд», чтобы открыть командную строку.
3. Теперь введите. \ bin \ windows \ kafka-server-start.bat. \ config \ server.properties и нажмите Enter.

4. Если все в порядке, командная строка должна выглядеть так:

5. Теперь, когда Kafka готов и работает, вы можете создавать темы для хранения сообщений. Мы также можем генерировать или использовать данные из кода Java / Scala или непосредственно из командной строки.

E. Создайте тему

Теперь создайте тему, назовите ее «test» и коэффициент репликации = 1 (потому что работает только 1 сервер Kafka). Если в кластере работает более одного сервера Kafka, вы можете соответственно увеличить коэффициент репликации, чтобы улучшить доступность данных и отказоустойчивость системы.
Откройте новую командную строку в C: \ kafka_2.11-0.9.0.0 \ bin \ windows.
Введите следующую команду и нажмите Enter:

F. Создайте производителя и потребителя для тестирования сервера.

1. Откройте новую командную строку в C: \ kafka_2.11-0.9.0.0 \ bin \ windows.
2. Введите следующую команду, чтобы запустить производитель:

3. Снова откройте новую командную строку в том же месте C: \ kafka_2.11-0.9.0.0 \ bin \ windows.
4. Теперь введите следующую команду для запуска потребителя:

5. Теперь есть два окна командной строки, как показано ниже:

6. Введите любой контент в командную строку производителя и нажмите Enter, вы увидите соответствующее сообщение в других командных строках потребителя.

7. Если сообщение можно отправить потребителю и отобразить, установка Kafka завершена.

Некоторые полезные команды

1. Список тем: kafka-themes.bat –list –zookeeper localhost: 2181
2. Опишите тему: kafka-themes.bat –describe –zookeeper localhost: 2181 –topic [Название темы]
3. Прочтите сообщение с самого начала: kafka-console-consumer.bat –zookeeper localhost: 2181 –topic [Название темы] –from-begin
4. Удалите тему: kafka-run-class.bat kafka.admin.TopicCommand –delete –topic [topic_to_delete] –zookeeper localhost: 2181

Исходный адрес:Setting Up and Running Apache Kafka on Windows OS
Автор статьи: Гопал Тивари
Переводчик: Сунь Вэй
Ответственный редактор: Чжун Хао

Интеллектуальная рекомендация

Пример сборки кластера SpringCloud Eureka

1. Описание Eureka предоставляет сервисы на основе REST, которые в основном используются для управления сервисами в кластерах. Для регистрации службы Spring Cloud и обнаружения экземпляра Spring Cloud.

Источник

Как установить Кафку на Windows?

Я пытаюсь установить очередь сообщений Kafka в Windows для тестирования (не для производства).

Это хорошая статья, но, к сожалению, она устарела.

Кто-нибудь знает способ достичь этого?

ОТВЕТЫ

Ответ 1

Хорошо, это, наконец, не сложно 🙂

Загрузите Кафку и разархивируйте ее где угодно (скажем, C:/Kafka )
Установить Cygwin

Отредактируйте \bin\kafka-run-class.sh и в конце файла измените

exec $JAVA $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp $CLASSPATH $KAFKA_OPTS «[email protected]»

exec java $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp ‘cygpath -wp $CLASSPATH’ $KAFKA_OPTS «[email protected]»

В разделе Переменные среды добавьте Java в путь системной переменной:

Вот это.. теперь вы можете запускать серверы ZooKeeper и Kafka и начать играть с темами и прочим..

Ответ 2

Шаги как follows-

Переменные среды Java должны быть установлены.
Перейдите на страницу загрузок Apache Kafka и загрузите Scala 2.12 kafka_2.12-0.10.2.1.tgz
Распакуйте его.

Откройте командную строку и запустите zookeeper-

Откройте новую командную строку и запустите Apache Kafka-

Откройте новую командную строку и создайте тему с именем javainuse-topic, которая имеет только один раздел и одну реплику.

C:\kafka_2.12-0.10.2.1>.\Bin\windows\Kafka- themes.bat —create — localhost: zookeeper: 2181 — коэффициент репликации 1 —partitions 1 —topic javainuse-topic

Далее откройте новую командную строку и создайте продюсера для отправки сообщения в созданную выше тему javainuse и отправьте сообщение — Hello World Javainuse на it-

C:\kafka_2.12-0.10.2.1>.\Bin\windows\Kafka- console -roduction.bat —broker-list localhost: 9092 —topic javainuse-topic

Привет, мир, Javainuse

Наконец, откройте новую командную строку и запустите получателя, который слушает тему javainuse-topic, которую мы только что создали. Мы получим сообщение, которое мы отправили, используя производителя

C:\kafka_2.12-0.10.2.1>.\Bin\windows\Kafka- console-consumer.bat —bootstrap-server localhost: 9092 —topic тема javainuse —from-begin

Подробные шаги, включая скриншоты и видео, доступны в этом blog- Начало работы с Apache Kafka

Ответ 3

Более точный ответ на благо кого-либо еще интересующегося об этом, я загрузил двоичный файл и все работало прямо из коробки. Исходная версия, однако, не работала.

Ответ 4

Это шаги, которые я выполнил для запуска kafka в Windows

Сначала установите Zookeeper (I скачано v3.3.6) zookeeper-3.3.6.tar.gz
Извлеките Zookeeper и запустите эту команду в powershell/cmd \zookeeper-3.3.6\bin> .\zkServer.cmd Теперь это должно привести к экземпляру Zookeeper на localhost:2181
Загрузите двоичную версию Kafka (I скачано v0.10.0.1) kafka_2.10-0.10.0.1.tgz
Извлеките Kafka, время для изменения некоторых конфигураций
Внутри экстракции Кафки вы можете найти .\config\server.properties
В .\config\server.properties заменить log.dirs=c:/kafka/kafka-logs
Примечание. Обязательно создайте эти папки в соответствующих путях.
Счастливые новости: теперь Kafka поставляется с окнами .bat-скриптами, вы можете найти эти файлы внутри папки ./bin/windows
Запустите powershell/cmd и запустите эту команду, чтобы запустить брокера Kafka .\bin\windows\kafka-server-start.bat .\config\server.properties
DONE!, Теперь у вас есть действующий экземпляр Zookeeper и брокера Kafka.

Ответ 5

Вероятно, вы обнаружите, что Kafka поставляется с Windows.bat файлами под папкой bin, чтобы помочь вам запустить Kafka под окнами. Однако эти файлы bat не обновляются с версии 0.8.0, а некоторые из правил Kafka изменились (в отношении тем и т.д.).

Я пробовал два способа решить эту проблему. Один из них — использовать Cygwin или MinGW для моделирования среды Linux и запуска оболочки Linux script, но было бы много других проблем, связанных с именами путей. Другое решение, которое проще и с меньшими проблемами, заключается в использовании исправленной версии файлов bat для Windows.

Пожалуйста, обратитесь к этому сообщению .

Ответ 6

Загрузите любую бинарную версию (я загрузил kafka_2.11-0.10.2.0) из Kafka из https://kafka.apache.org/downloads
Извлеките его в любую папку (я извлек ее в папку «C:\Kafka» )
Открыть командную строку
Перейдите в папку, в которой вы извлекаете Kafka (C:\Kafka\kafka_2.11-0.10.2.0)
Запустите эту команду .\bin\windows\zookeeper-server-start.bat.\config\zookeeper.properties, чтобы запустить Zookeeper
Запустите эту команду .\bin\windows\kafka-server-start.bat.\config\server.properties, чтобы запустить Kafka

Теперь он работает!

Ответ 7

В версии 0.9.0. в папке «bin» для Windows есть скрипты. Вы можете использовать их.

Ответ 8

Запуск из оболочки Windows

По состоянию на апрель 2019 года загрузка Kafka с их сайта работала на Windows практически сразу из коробки.

Загрузка и использование файлов Windows.bat версии описана здесь: https://kafka.apache.org/quickstart

Я столкнулся с двумя проблемами, когда я сделал это:

1) JAVA_HOME был установлен на неподдерживаемый JDK, что привело к такого рода ошибке

Исключение в потоке «main» java.lang.VerifyError: Неинициализированный объект существует в обратной ветки 209

Замена на JDK 11 решила проблему.

2) JAVA_HOME не должен содержать пробелов, которые привели к ошибке «не удается найти указанный файл». Чтобы исправить это, я использовал сокращенный путь, такой как set JAVA_HOME=C:\Progra

Работает от Cygwin

Если вместо .bat файлов вы хотите запустить .sh файлы из cygwin, на самом деле нужно сделать совсем немного, и даже после этого могут возникнуть проблемы, которые появятся позже. Я не могу порекомендовать эту опцию, но я использую ее, так как она довольно удобна для некоторых целей.

Если ваш путь JAVA_HOME содержит пробел, например «C:\Program Files\Java\Jdk. «, вы увидите что-то вроде этого:

bin/kafka-run-class.sh: строка 305: exec: C:\Программа: не найдена

Одним из решений является копирование JDK в путь без пробелов и соответствующее изменение домашней страницы Java.

Если вы не хотите изменять местоположение JDK, вы можете изменить переменную cygwin env следующим образом:

и изменить линию

Была другая проблема с параметрами журнала в kafka-run-class.sh, и мне пришлось заменить строку

И даже после всех этих изменений я иногда сталкиваюсь с проблемами выключения Kafka из-за несовместимого пути стиля Windows в каталогах журналов, как описано здесь: Kafka 1.0 останавливается с ошибкой FATAL SHUTDOWN. Сбой каталога журналов Короче говоря, вам может быть лучше запустить сценарии Kafka.bat из каталога Windows.

Ответ 9

Я еще не пробовал.

Ответ 10

Да, я настроил ZOOKEEPER и Apache Kafka на моей Windows-машине. Для ZOOKEEPER просто настройте ZOOKEEPER_HOME и установите путь, а затем переименуйте zoo.sample.cfg в zoo.cfg, а также измените путь для dataDir в zoo.cfg

Для Apache Kafka просто разархивируйте и запустите сервер из папки bin и запустите Producer/Consumer из папки Windows в каталоге Kafka

Ответ 11

С Chocolatey и Powershell:

chocolatey.exe install kafka → устанавливает Kafka в C:\ProgramData\chocolatey\lib\kafka\tools\kafka_2.11-1.0.0\ — ваша версия может отличаться, конечно.
добавьте C:\ProgramData\chocolatey\lib\kafka\tools\kafka_2.11-1.0.0\ в свой путь powershell, используя notepad $PROFILE

После перезапуска powershell kafka-console-consumer должен работать как команда.

Вам также необходимо установить ssl.properties с хранилищем ключей и доверительным магазином. Положите их, например. в C:\ProgramData\kafka и поместите это в ssl.properties (обратите внимание на ускорение обратных косых черт):

Теперь такие вещи, как kafka-consumer-groups —bootstrap-server SERVERNAME:9094 —command-config C:\ProgramData\kafka\ssl.properties —list , должны сначала вызвать предупреждение брандмауэра, которое необходимо принять, а затем вывести список групп.

Ответ 12

Это старая ветка, но для тех, кто читает это в 2018 году, я предлагаю запустить kafka в докере. Один из многих учебных пособий по этому поводу: https://iteritory.com/kafka-docker-image-installation-usage-tutorial-windows/

Ответ 13

Я только что попытался установить Apache Kafka на Windows несколько дней назад и записал шаги в посте Установка и настройка Kafka на Windows. Надеюсь, это поможет вам.

Ответ 14

Обратитесь к официальной документации,

На платформах Windows используйте bin\windows\ вместо bin/ и измените расширение скрипта на .bat .

Источник

Настройка и запуск Apache Kafka в ОС Windows

В моей последней статье мы рассмотрели настройку и использование Hadoop. Эта статья посвящена настройке и запуску сервера Apache Kafka в ОС Windows. Это руководство также содержит инструкции по настройке Java и Apache ZooKeeper.

Apache Kafka — это быстрая и масштабируемая очередь обмена сообщениями, способная обрабатывать большие нагрузки в контексте чтения и записи, то есть вещей, связанных с IO. Вы можете найти больше информации о Кафке на http://kafka.apache.org/ . Для Apache Kafka требуется работающий экземпляр ZooKeeper, который используется для надежной распределенной координации. Пожалуйста, узнайте больше о ZooKeeper на https://zookeeper.apache.org/ .

Из этого видео вы можете получить помощь по настройке Kafka в Windows.

Авторский GitHub:

Я создал несколько утилит Spark-Scala по адресу https://github.com/gopal-tiwari , которые могут быть полезны в некоторых других случаях.

Скачивание необходимых файлов

Загрузите серверную JRE в соответствии с вашей ОС и архитектурой процессора с http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html
Загрузите и установите 7-zip с http://www.7-zip.org/download.html
Загрузите и распакуйте ZooKeeper, используя 7-zip с http://zookeeper.apache.org/releases.html
Загрузите и распакуйте Kafka, используя 7-zip с http://kafka.apache.org/downloads.html

В этом руководстве мы предполагаем, что ZooKeeper и Kafka разархивированы на диске C :, но вы можете разархивировать их в любом месте.

Здесь мы используем полноценный ZooKeeper, а не тот, который поставляется вместе с Kafka, потому что это будет одноузловой экземпляр ZooKeeper. Если вы хотите, вы можете запустить Kafka с упакованным ZooKeeper, расположенным в пакете Kafka в каталоге \ kafka \ bin \ windows .

Монтаж

A. Настройка JDK

1. Запустите установку JRE и установите флажок «Изменить папку назначения», затем нажмите «Установить».

2. Измените каталог установки на любой путь без пробелов в имени папки. Например, C: \ Java \ jre1.8.0_xx \. (По умолчанию это будет C: \ Program Files \ Java \ jre1.8.0_xx), затем нажмите «Далее».

3. Теперь откройте диалоговое окно системных переменных среды, открыв Панель управления -> Система -> Расширенные настройки системы -> Переменные среды.

4. Нажмите кнопку «Новая переменная пользователя» в разделе «Пользовательские переменные», затем введите «JAVA_HOME» в поле «Имя переменной» и укажите свой путь jre в значении переменной. Это должно выглядеть как на картинке ниже:

(Путь и версия Java могут меняться в зависимости от используемой вами версии Kafka)

5. Теперь нажмите ОК.

6. Найдите переменную Path в разделе «Системная переменная» в диалоговом окне «Переменные среды», которое вы только что открыли.

7. Отредактируйте путь и введите «;% JAVA_HOME% \ bin» в конце уже написанного текста, как показано на рисунке ниже:

8. Чтобы подтвердить установку Java, просто откройте cmd и введите « java –version». Вы должны увидеть версию Java, которую вы только что установили.

Если ваша командная строка выглядит примерно так, как на картинке выше, вы готовы. В противном случае вам необходимо перепроверить, соответствует ли ваша установочная версия правильной архитектуре ОС (x86, x64) или путь переменных среды является правильным.

B. Установка ZooKeeper

1. Перейдите в каталог конфигурации ZooKeeper. Для меня это C: \ zookeeper-3.4.7 \ conf

2. Переименуйте файл «zoo_sample.cfg» в « zoo.cfg».

3. Откройте zoo.cfg в любом текстовом редакторе, например «Блокнот»; Я предпочитаю Notepad ++.

4. Найти и редактировать dataDir=/tmp/zookeeper to :\zookeeper-3.4.7\data

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

Источник

How to install Kafka on Windows?

I’m trying to install Kafka message queue on Windows for testing purposes (not for production).

It’s a good article, but it’s outdated, unfortunately.

Does someone know a way to achieve that?

12 Answers 12

Ok, it’s finally not complicated 🙂

The only steps are:

Download Kafka and uncompress it somewhere nice (let’s say C:/Kafka )
Install Cygwin

Edit \bin\kafka-run-class.sh and at the end of the file, change

exec $JAVA $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp $CLASSPATH $KAFKA_OPTS «$@»

exec java $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp `cygpath -wp $CLASSPATH` $KAFKA_OPTS «$@»

In Environment Variables, Add java to your Path System Variable:

That’s it.. you can now run ZooKeeper and Kafka servers and start playing with topics and stuff..

These are the steps I followed to run kafka on Windows

Install Zookeeper first (I downloaded v3.3.6) zookeeper-3.3.6.tar.gz
Extract Zookeeper and run this command in powershell/cmd \zookeeper-3.3.6\bin> .\zkServer.cmd Now this should up a Zookeeper instance on localhost:2181
Download Kafka binary version (I downloaded v0.10.0.1) kafka_2.10-0.10.0.1.tgz
Extract Kafka, time to modify some configs
Inside Kafka extraction you can find .\config\server.properties
In .\config\server.properties replace log.dirs=c:/kafka/kafka-logs
Note: Make sure to create those folders in relevant paths
Happy news: Now Kafka ships with windows .bat scripts, You can find these files inside ./bin/windows folder
Start powershell/cmd and run this command to start Kafka broker .\bin\windows\kafka-server-start.bat .\config\server.properties
DONE!, Now you have a running Zookeeper instance and a Kafka broker.

A more current answer for the benefit of anyone else still wondering about this, I downloaded the binary and everything worked right out of the box. The source version, however, didn’t work.

You will probably find that Kafka comes with Windows .bat files under the bin folder to help you run Kafka under windows. However, those bat files are not updated since version 0.8.0 and some of Kafka’s logic has changed (regarding topics, etc.).

I have tried two ways to solve this problem. One is to use Cygwin or MinGW to simulate Linux environment and run the Linux shell script, but there would be tons of other problems related to path names. The other solution, which is simpler and come with less trouble, is to use the corrected version of Windows bat files.

Please refer to this blog post.

Download any binary version(I’ve downloaded kafka_2.11-0.10.2.0) of Kafka from https://kafka.apache.org/downloads
Extract it to any folder(I’ve extracted to «C:\Kafka»)
Open Command Prompt
Go to the folder that you extract Kafka(C:\Kafka\kafka_2.11-0.10.2.0)
Run this command .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties to start Zookeeper
Run this command .\bin\windows\kafka-server-start.bat .\config\server.properties to start Kafka

In version 0.9.0. there are scripts in «bin» folder for windows. You can use them.

Running From A windows Shell

As of April 2019, downloading Kafka from their website worked on Windows almost right out of the box

Downloading and using the windows version .bat files is described here: https://kafka.apache.org/quickstart

I ran into two problems when I did this:

1) JAVA_HOME was set to an unsupported JDK which led to this kind of error

Exception in thread «main» java.lang.VerifyError: Uninitialized object exists on backward branch 209

Replacing with JDK 11 solved the problem.

2) The JAVA_HOME must not contain spaces which caused a ‘cannot find the specified file’ error. To fix this I used a shortened path like set JAVA_HOME=C:\Progra

Running From Cygwin

If instead of the .bat files, you want to run the .sh files from cygwin, there is actually quite a bit that needs to be done, and even after that there may be problems that come up later. I can’t really recommend this option, but I do use it as it’s pretty convenient for some purposes.

If your JAVA_HOME path contains a space e.g. «C:\Program Files\Java\Jdk. » you will see something like this:

bin/kafka-run-class.sh: line 305: exec: C:\Program: not found

One solution is to copy the jdk to a path without spaces, and change the Java home accordingly.

If you don’t want to change the JDK location, you can change the cygwin env variable as follows:

and change the line

There was another problem with the log parameters in kafka-run-class.sh and I had to replace the line

And even after all these changes I occasionally run into problems of Kafka shutting down because of an incompatible windows style path in the logs directories as described here: Kafka 1.0 stops with FATAL SHUTDOWN error. Logs directory failed In short, you may be better off running the Kafka .bat scripts from the windows directory.

Источник