Apache Kafka 安裝步驟

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

步驟1 - 驗證Java安裝

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

$ java -version

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

步驟1.1 - 下載JDK

如果沒有下載Java，請通過訪問以下鏈接并下載最新版本來下載最新版本的JDK。

現(xiàn)在最新的版本是JDK 8u 60，文件是“jdk-8u60-linux-x64.tar.gz"。 請在您的機(jī)器上下載該文件。

步驟1.2 - 提取文件

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

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

步驟1.3 - 移動到選擇目錄

要將java提供給所有用戶，請將提取的java內(nèi)容移動到 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變量，請將以下命令添加到?/ .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步中說明的驗證命令(java -version)驗證java。

步驟2 - ZooKeeper框架安裝

步驟2.1 - 下載ZooKeeper

要在您的計算機(jī)上安裝ZooKeeper框架，請訪問以下鏈接并下載最新版本的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"打開名為 conf / zoo.cfg 的配置文件，并將所有以下參數(shù)設(shè)置為起點。

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

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

步驟2.4 - 啟動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 - 啟動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，請點擊以下鏈接 -

現(xiàn)在最新版本，即 - kafka_2.11_0.9.0.0.tgz 將下載到您的計算機(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 - 啟動服務(wù)器

您可以通過給出以下命令來啟動服務(wù)器 -

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

服務(wù)器啟動后，您會在屏幕上看到以下響應(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í)如何對Kafka執(zhí)行基本操作。