Запуск сервера Corax#

Выполните запуск сервера Corax в следующем порядке:

1. Запуск узла Corax:

   • Запуск ZooKeeper:

     > bin/zookeeper-server-start.sh config/zookeeper.properties
     
      [2015-03-09 15:01:37,495]  INFO Reading configuration from config/zookeeper.properties (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
      # ...
     

     Где config/zookeeper.properties — файл конфигурации ZooKeeper.

   • Запуск узла Corax:

     > bin/kafka-server-start.sh config/server.properties
     
      [2015-03-09 15:02:37,495]  INFO Verifying properties (kafka.utils.VerifiableProperties)
      [2015-03-09 15:02:37,495]  INFO Property socket.send.buffer.bytes is overridden to 1048576 (kafka.utils.VerifiableProperties)
     # ...
     

     Где config/server.properties — конфигурационный файл узла (брокера) Corax.

   • Запуск узлов ZooKeeper и Corax в фоновом режиме:

     > bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
     > bin/kafka-server-start.sh -daemon config/server.properties
     

     Где -daemon — опция для запуска в фоновом режиме.

     Запуск в фоновом режиме является рекомендуемым способом для эксплуатации.

     Чтение лог-файлов ZooKeeper и Corax при запуске в фоновом режиме:

     • логи приложения ZooKeeper выводятся в файл logs/zookeeper.out;

     • логи приложения Corax выводятся в файл logs/server.log.

     Запуск узлов ZooKeeper и Corax в фоновом режиме с выводом логов из файла в консоль:

     > bin/zookeeper-server-start.sh -daemon \
     config/zookeeper.properties && tail -f logs/zookeeper.out
     
     > bin/kafka-server-start.sh -daemon \
     config/server.properties && tail -f logs/server.log
     

2. Для остановки узлов Corax и ZooKeeper выполните скрипты в следующем порядке:

   > bin/kafka-server-stop.sh
   > bin/zookeeper-server-stop.sh
   

3. Для проверки состояния процессов узлов ZooKeeper и Corax воспользуйтесь поиском PID этих процессов в оперативной памяти:

   • Проверка состояния узла Corax с помощью поиска PID его процесса:

     > ps ax | grep -i 'kafka \. Kafka' | grep java | grep -v grep | awk '{print $1}'
     
     1234
     

     В результате выведется PID найденного процесса или пустая строка в случае его отсутствия.

   • Проверка состояния узла Corax командой, запрашивающей список топиков:

     > bin/kafka-topics.sh --list --zookeeper localhost:2181
     
     # ...
     __ consumer _ offsets
     # ...
     

     Где:

     • --list — опция, обозначающая режим вывода списка топиков;

     • --zookeeper — хост ZooKeeper в формате IP:Port;

     • localhost — имя IP-адреса сервера, на котором запущен ZooKeeper;

     • 2181 — порт clientPort, задаваемый в файле конфигураций config/zookeeper.properties для ZooKeeper, через который осуществляется подключение клиентов.

     В результате будет выведен список топиков, в котором, например, может содержаться топик __ consumer _ offsets (если к этому топику подключался Потребитель).

     Примечания

     1. В текущей версии указанная команда будет работать только при отключенном SSL.

     2. Использование параметра --zookeeper для текущей версии считается устаревшим.

   • Проверка состояния узла ZooKeeper с помощью поиска PID его процесса:

     > ps ax | grep -i 'zookeeper' | grep -v grep | awk '{print $1}'
     
     1234
     

     В результате выведется PID найденного процесса или пустая строка в случае его отсутствия.