Apache Kafka 安裝步驟

以下是在機(jī)器上安裝Java的步驟。

步驟1 - 驗(yàn)證Java安裝

希望你已經(jīng)在你的機(jī)器上安裝了java，所以你只需使用下面的命令驗(yàn)證它。

$ java -version

如果java在您的機(jī)器上成功安裝，您可以看到已安裝的Java的版本。

步驟1.1 - 下載JDK

如果沒(méi)有下載Java，請(qǐng)通過(guò)訪問(wèn)以下鏈接并下載最新版本來(lái)下載最新版本的JDK。

現(xiàn)在最新的版本是JDK 8u 60，文件是“jdk-8u60-linux-x64.tar.gz"。 請(qǐng)?jiān)谀臋C(jī)器上下載該文件。

步驟1.2 - 提取文件

通常，正在下載的文件存儲(chǔ)在下載文件夾中，驗(yàn)證它并使用以下命令提取tar設(shè)置。

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

步驟1.3 - 移動(dòng)到選擇目錄

要將java提供給所有用戶，請(qǐng)將提取的java內(nèi)容移動(dòng)到 usr / local / java / folder。

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

步驟1.4 - 設(shè)置路徑

要設(shè)置路徑和JAVA_HOME變量，請(qǐng)將以下命令添加到?/ .bashrc文件。

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

現(xiàn)在將所有更改應(yīng)用到當(dāng)前運(yùn)行的系統(tǒng)。

$ source ~/.bashrc

步驟1.5 - Java替代

使用以下命令更改Java Alternatives。

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

步驟1.6 - 現(xiàn)在使用第1步中說(shuō)明的驗(yàn)證命令(java -version)驗(yàn)證java。

步驟2 - ZooKeeper框架安裝

步驟2.1 - 下載ZooKeeper

要在您的計(jì)算機(jī)上安裝ZooKeeper框架，請(qǐng)?jiān)L問(wèn)以下鏈接并下載最新版本的ZooKeeper。

現(xiàn)在，最新版本的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 - 創(chuàng)建配置文件

使用命令vi“conf / zoo.cfg"打開(kāi)名為 conf / zoo.cfg 的配置文件，并將所有以下參數(shù)設(shè)置為起點(diǎn)。

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

一旦配置文件成功保存并再次返回終端，您可以啟動(dòng)zookeeper服務(wù)器。

步驟2.4 - 啟動(dòng)ZooKeeper服務(wù)器

$ bin/zkServer.sh start

執(zhí)行此命令后，您將得到如下所示的響應(yīng) -

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

步驟2.5 - 啟動(dòng)CLI

$ bin/zkCli.sh

輸入上面的命令后，您將被連接到zookeeper服務(wù)器，并將獲得以下響應(yīng)。

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

步驟2.6 - 停止Zookeeper服務(wù)器

連接服務(wù)器并執(zhí)行所有操作后，可以使用以下命令停止zookeeper服務(wù)器 -

$ bin/zkServer.sh stop

現(xiàn)在你已經(jīng)在你的機(jī)器上成功安裝了Java和ZooKeeper。 讓我們看看安裝Apache Kafka的步驟。

步驟3 - Apache Kafka安裝

讓我們繼續(xù)以下步驟在您的機(jī)器上安裝Kafka。

步驟3.1 - 下載Kafka

要在您的機(jī)器上安裝Kafka，請(qǐng)點(diǎn)擊以下鏈接 -

現(xiàn)在最新版本，即 - kafka_2.11_0.9.0.0.tgz 將下載到您的計(jì)算機(jī)上。

步驟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

現(xiàn)在您已經(jīng)在您的機(jī)器上下載了最新版本的Kafka。

步驟3.3 - 啟動(dòng)服務(wù)器

您可以通過(guò)給出以下命令來(lái)啟動(dòng)服務(wù)器 -

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

服務(wù)器啟動(dòng)后，您會(huì)在屏幕上看到以下響應(yīng):

$ 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 - 停止服務(wù)器

執(zhí)行所有操作后，可以使用以下命令停止服務(wù)器 -

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

現(xiàn)在我們已經(jīng)討論了Kafka安裝，我們可以在下一章中學(xué)習(xí)如何對(duì)Kafka執(zhí)行基本操作。