Дистрибутивы

Необходимо скачать targzip архивы:

  1. Zookeeper - D:\Programs\kafka\kafka_2.12-0.11.0.0\config\server.properties
  2. Kafka - версия 0.11.0.0 со страницы https://kafka.apache.org/downloads 


Настройка

Zookeper

  1. Распакуйте архив, например в директорию D:\Programs\zookeeper\ . Получится, что распакованный дистрибутив лежит в D:\Programs\zookeeper\zookeeper-3.4.14 . Будем считать этот путь директорией установки zookeeper. 
  2. В папке conf в директории установки zookeeper переименовываем файл zoo_sample.cfg в zoo.cfg
  3. В файле zoo.cfg в настройке dataDir устанавливаем путь к директории, где zookeper будет хранить свои данные в unix формате. Например /tmp/zookeeper

Kafka

  1. Распакуйте архив, например в директорию D:\Programs\kafka\ . Получится, что распакованный дистрибутив лежит в D:\Programs\kafka\kafka_2.12-0.11.0.0\ . Будем считать этот путь директорией установки kafka. 
  2. В папке config в директории установки kafka редактируем файл server.properties. Устанавливаем свойство log.dirs на путь к директории где kafka будет хранить свои данные. Например /tmp/kafka

Старт

  1. Сначала стартуем zookeeper. Из директории bin в директории установки zookeper запускаем zkServer.cmd
  2. Стартуем kafka. В директории bin/windows в директории установки kafka запускаем
kafka-server-start.bat ../../config/server.properties

Проверка работы

Список топиков

В директории bin/windows в директории установки kafka запускаем

kafka-topics.bat --zookeeper localhost:2181 --list

Публикация сообщения в топик

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


Чтение сообщений из топика

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test


Остановка

В директории bin/windows в директории установки kafka запускаем kafka-server-stop.bat

Из консоли где работает zookeeper вызываем Ctrl+C.

  • Нет меток