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: https://www.yiibai.com/java/how-to-install-java-on-ubuntu.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上執行基本操作。