Kafka環境安裝組態


以下是在您的機器上安裝Java的步驟。

第1步 - Java安裝

檢視是否在機器上安裝了java環境,只需使用下面的命令來驗證它。

$ java -version

如果計算機上已成功安裝Java,則可以看到已安裝的Java版本。例如 -

yiibai@ubuntu:~$ java -version
java version "1.8.0_65"
Java(TM) SE Runtime Environment (build 1.8.0_65-b17)
Java HotSpot(TM) Client VM (build 25.65-b01, mixed mode)
yiibai@ubuntu:~$

如果沒有安裝好Java,那麼可以參考以下步驟來安裝。

Ubuntu上安裝Java: /20/206/8034.html

第2步 - ZooKeeper框架安裝

步驟2.1 - 下載ZooKeeper

要在您的機器上安裝ZooKeeper框架,請存取以下連結並下載最新版本的ZooKeeper。URL: http://zookeeper.apache.org/releases.html , 截至目前,ZooKeeper的最新版本是:3.4.10(ZooKeeper-3.4.10.tar.gz)。

步驟2.2 - 解壓縮tar檔案

使用以下命令提取tar檔案

$ cd /usr/local/src
$ wget -c http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz
$ tar -zxf zookeeper-3.4.10.tar.gz 
$ mv zookeeper-3.4.10 /usr/local/
$ cd /usr/local/zookeeper-3.4.10
$ mkdir /usr/local/zookeeper-3.4.10/data

步驟2.3 - 建立組態檔案

使用vi conf/zoo.cfg命令開啟conf/zoo.cfg組態檔案,並將以下引數內容寫入在檔案的開頭。

tickTime=2000
dataDir=/usr/local/zookeeper-3.4.10/data
clientPort=2181
initLimit=5
syncLimit=2

當組態檔案儲存成功並再次返回到終端,可以啟動zookeeper伺服器。

步驟2.4 - 啟動ZooKeeper伺服器

$ /usr/local/zookeeper-3.4.10/bin/zkServer.sh start

執行此命令後,將得到如下所示的響應 -

ZooKeeper JMX enabled by default
Using config: /usr/local/zookeeper-3.4.10/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
yiibai@ubuntu:/usr/local/zookeeper-3.4.10$

步驟2.5 - 啟動CLI

$ /usr/local/zookeeper-3.4.10/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伺服器 -

$ /usr/local/zookeeper-3.4.10/bin/zkServer.sh stop

經過前面的操作,現在已經在機器上成功安裝了Java和ZooKeeper。 接下來看看如何來安裝Apache Kafka。

第3步 - Apache Kafka安裝

下面繼續以下步驟來安裝Kafka。

步驟3.1 - 下載Kafka

要在您的機器上安裝Kafka,請點選下面的連結 -

http://mirrors.hust.edu.cn/apache/kafka/1.0.1/kafka_2.11-1.0.1.tgz

把現在最新的版本,即 - kafka_2.11_0.9.0.0.tgz 下載到您的機器上。

步驟3.2 - 提取tar檔案

使用以下命令提取tar檔案 -

$ cd /usr/local/src
$ wget -c http://mirrors.hust.edu.cn/apache/kafka/1.0.1/kafka_2.11-1.0.1.tgz
$ tar -zxf kafka_2.11-1.0.1.tgz
$ mv kafka_2.11-1.0.1 /usr/local/
$ cd /usr/local/kafka_2.11-1.0.1

現在已經下載並解壓了最新版本的Kafka。

步驟3.3 - 啟動伺服器

可以通過提供以下命令啟動伺服器 -

注意:需要先啟動 zookeeper

$ /usr/local/kafka_2.11-1.0.1/bin/kafka-server-start.sh config/server.properties

伺服器啟動後,會在終端上看到以下響應 -

[2018-03-12 01:43:42,213] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
[2018-03-12 01:43:42,223] INFO Registered broker 0 at path /brokers/ids/0 with addresses: EndPoint(ubuntu,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.utils.ZkUtils)
[2018-03-12 01:43:42,239] WARN No meta.properties file under dir /tmp/kafka-logs/meta.properties (kafka.server.BrokerMetadataCheckpoint)
[2018-03-12 01:43:42,323] INFO Kafka version : 1.0.1 (org.apache.kafka.common.utils.AppInfoParser)
[2018-03-12 01:43:42,326] INFO Kafka commitId : c0518aa65f25317e (org.apache.kafka.common.utils.AppInfoParser)
[2018-03-12 01:43:42,330] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)
…………………………………………….
…………………………………………….

第4步 - 停止伺服器

執行所有操作後,可以使用以下命令停止伺服器 -

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

通過前面的步驟和操作,我們已經安裝好了Kafka,在下一章中將學習如何在Kafka上執行基本操作。