Apache Kafka - шаги по установке

Ниже приведены шаги по установке Java на ваш компьютер.

Шаг 1. Проверка установки Java

Надеюсь, вы уже установили java на свой компьютер прямо сейчас, поэтому просто проверьте его, используя следующую команду.

$ java -version

Если Java успешно установлена ​​на вашем компьютере, вы можете увидеть версию установленной Java.

Шаг 1.1 - Загрузите JDK

Если Java не загружена, загрузите последнюю версию JDK, перейдя по следующей ссылке, и загрузите последнюю версию.

http://www.oracle.com/technetwork/java/javase/downloads/index.html

Теперь последняя версия - JDK 8u 60, а файл - «jdk-8u60-linux-x64.tar.gz». Загрузите файл на свой компьютер.

Шаг 1.2 - Извлечение файлов

Как правило, загружаемые файлы хранятся в папке загрузок, проверьте ее и извлеките установку tar с помощью следующих команд.

$ cd /go/to/download/path
$ tar -zxf jdk-8u60-linux-x64.gz

Шаг 1.3 - Перейти в каталог Opt

Чтобы сделать Java доступной для всех пользователей, переместите извлеченное содержимое Java в папку usr / local / java /.

$ su
password: (type password of root user)
$ mkdir /opt/jdk
$ mv jdk-1.8.0_60 /opt/jdk/

Шаг 1.4 - Установите путь

Чтобы установить путь и переменные JAVA_HOME, добавьте следующие команды в файл ~ / .bashrc.

export JAVA_HOME =/usr/jdk/jdk-1.8.0_60
export PATH=$PATH:$JAVA_HOME/bin

Теперь примените все изменения к текущей работающей системе.

$ source ~/.bashrc

Шаг 1.5 - Альтернативы Java

Используйте следующую команду, чтобы изменить альтернативы Java.

update-alternatives --install /usr/bin/java java /opt/jdk/jdk1.8.0_60/bin/java 100

Step 1.6 - Теперь проверьте Java с помощью команды проверки (java -version), описанной в шаге 1.

Шаг 2 - Установка ZooKeeper Framework

Шаг 2.1 - Загрузите ZooKeeper

Чтобы установить ZooKeeper framework на свой компьютер, перейдите по следующей ссылке и загрузите последнюю версию ZooKeeper.

http://zookeeper.apache.org/releases.html

На данный момент последняя версия ZooKeeper - 3.4.6 (ZooKeeper-3.4.6.tar.gz).

Шаг 2.2 - Извлечение tar-файла

Извлеките tar-файл с помощью следующей команды

$ cd opt/
$ tar -zxf zookeeper-3.4.6.tar.gz
$ cd zookeeper-3.4.6
$ mkdir data

Шаг 2.3 - Создание файла конфигурации

Откройте файл конфигурации с именем conf / zoo.cfg, используя команду vi «conf / zoo.cfg» и все следующие параметры, чтобы установить их в качестве отправной точки.

$ vi conf/zoo.cfg
tickTime=2000
dataDir=/path/to/zookeeper/data
clientPort=2181
initLimit=5
syncLimit=2

После того, как файл конфигурации будет успешно сохранен и снова вернется в терминал, вы можете запустить сервер zookeeper.

Шаг 2.4 - Запустите сервер ZooKeeper

$ bin/zkServer.sh start

После выполнения этой команды вы получите ответ, как показано ниже -

$ JMX enabled by default
$ Using config: /Users/../zookeeper-3.4.6/bin/../conf/zoo.cfg
$ Starting zookeeper ... STARTED

Шаг 2.5 - Запустите CLI

$ bin/zkCli.sh

После ввода указанной выше команды вы будете подключены к серверу zookeeper и получите ответ ниже.

Connecting to localhost:2181
................
................
................
Welcome to ZooKeeper!
................
................
WATCHER::
WatchedEvent state:SyncConnected type: None path:null
[zk: localhost:2181(CONNECTED) 0]

Шаг 2.6 - Остановка сервера Zookeeper

После подключения сервера и выполнения всех операций вы можете остановить сервер zookeeper с помощью следующей команды -

$ bin/zkServer.sh stop

Теперь вы успешно установили Java и ZooKeeper на свой компьютер. Давайте посмотрим, как установить Apache Kafka.

Шаг 3 - установка Apache Kafka

Давайте продолжим следующие шаги, чтобы установить Kafka на ваш компьютер.

Шаг 3.1 - Загрузите Kafka

Чтобы установить Kafka на свой компьютер, щелкните ссылку ниже -

https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.0/kafka_2.11-0.9.0.0.tgz

Теперь последняя версия, то есть - kafka_2.11_0.9.0.0.tgz будет загружен на ваш компьютер.

Шаг 3.2 - Извлеките tar-файл

Извлеките файл tar, используя следующую команду -

$ cd opt/
$ tar -zxf kafka_2.11.0.9.0.0 tar.gz
$ cd kafka_2.11.0.9.0.0

Теперь вы загрузили последнюю версию Kafka на свой компьютер.

Шаг 3.3 - Запуск сервера

Вы можете запустить сервер, введя следующую команду -

$ bin/kafka-server-start.sh config/server.properties

После запуска сервера вы увидите на экране следующий ответ:

$ bin/kafka-server-start.sh config/server.properties
[2016-01-02 15:37:30,410] INFO KafkaConfig values:
request.timeout.ms = 30000
log.roll.hours = 168
inter.broker.protocol.version = 0.9.0.X
log.preallocate = false
security.inter.broker.protocol = PLAINTEXT
…………………………………………….
…………………………………………….

Шаг 4 - Остановите сервер

После выполнения всех операций вы можете остановить сервер с помощью следующей команды -

$ bin/kafka-server-stop.sh config/server.properties

Теперь, когда мы уже обсудили установку Kafka, мы можем узнать, как выполнять основные операции с Kafka в следующей главе.