Table of Contents

Kafka – Linux 環(huán)境（CentOS 7）的詳細安裝步驟（含Zookeeper）

在開始正式安裝之前，先簡單說下整個系統(tǒng)運行的順序：

1. 啟動 zookeeper server。

2. 啟動 kafka server。

3. Producer 如果生產(chǎn)了數(shù)據(jù)，會先通過 zookeeper 找到 broker，然后將數(shù)據(jù)存放進 broker。

4. Consumer 如果要消費數(shù)據(jù)，會先通過 zookeeper 找對應(yīng)的 broker，然后消費。

除了可以直接安裝Kafka Server之外，還可以通過 Docker 運行Kafka Server，可以參考：

Docker環(huán)境下安裝Zookeeper和Kafka

下面開始在Linux（CentOS 7）環(huán)境下，正式安裝Kafka Server 最新版本。

1.安裝Java，確認Java版本；

Linux 環(huán)境 – 安裝JDK

Step 1.1 – 下載Java JDK 壓縮包

Step 1.2 – Extract Files 解壓縮文件

下載完成之后，解壓tar文件。

$ cd /go/to/download/path

$ tar -zxf jdk-8u60-linux-x64.gz

Step 1.3 – 移動 JDK 到 opt 目錄

$ su

password: (type password of root user)

$ mkdir /opt/jdk

$ mv jdk-1.8.0_60 /opt/jdk/

Step 1.4 – Set path 設(shè)置 JAVA_HOME

vim /etc/profile

2. 安裝Zookeeper

Step 2.1 – 下載 ZooKeeper

訪問如下鏈接，下載最新版本的ZooKeeper，安裝Zookeeper。

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

As of now, latest version of ZooKeeper is 3.4.6 (ZooKeeper-3.4.6.tar.gz).

最新版本：

http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.11/

Step 2.2 – 解壓文件

使用下面的命令，解壓tar文件。

$ cd opt/

$ tar -zxf zookeeper-3.4.6.tar.gz

$ cd zookeeper-3.4.6

$ mkdir data

Step 2.3 – 創(chuàng)建配置文件

復(fù)制zoocfg 文件 — cp zoo_sample.cfg zoo.cfg

$ vi conf/zoo.cfg

tickTime=2000

dataDir=/path/to/zookeeper/data?-> /opt/zookeeper-3.4.11/data

clientPort=2181

initLimit=5

syncLimit=2

修改并保存好配置文件之后，返回到terminal窗口，啟動Zookeeper server。

Step 2.4 – 啟動ZooKeeper

$ bin/zkServer.sh start

在執(zhí)行上述命令后，將看到如下輸出：

$ JMX enabled by default

$ Using config: /Users/../zookeeper-3.4.6/bin/../conf/zoo.cfg

$ Starting zookeeper … STARTED

使用jps 查看 java process status

查看ZooKeeper Server的狀態(tài)：

[root@local zookeeper-3.4.11]# bin/zkServer.sh status

ZooKeeper JMX enabled by default

Using config: /opt/zookeeper-3.4.11/bin/../conf/zoo.cfg

Mode: standalone

[root@local zookeeper-3.4.11]#

Step 2.5 – 啟動CLI

$ bin/zkCli.sh

輸入上述命令，將連接到Zookeeper 服務(wù)器，并看到如下輸出。

Connecting to localhost:2181

…………….

…………….

…………….

Welcome to ZooKeeper!

…………….

…………….

WATCHER::

WatchedEvent state:SyncConnected type: None path:null

[zk: localhost:2181(CONNECTED) 0]

Step 2.6 – 停止ZooKeeper服務(wù)器

在連接服務(wù)器，執(zhí)行完操作之后，可以停止Zookeeper 服務(wù)器，執(zhí)行下面的命令即可。

$ bin/zkServer.sh stop

現(xiàn)在，我們已經(jīng)成功安裝好了Java和Zookeeper。接下來，開始安裝Apache Kafka。

Step 3 – 安裝Kafka

接著按照如下步驟安裝Kafka。

Step 3.1 -下載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，下載到本地。

Step 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)完成下載最新版本的kafka。

Step 3.3 – 啟動Kafka Server

Kafka 需要使用ZooKeeper，因此你需要首先啟動ZooKeeper 服務(wù)器。

你也可以使用如下腳本，運行一個單一節(jié)點的ZooKeeper 實例。

啟動ZooKeeper Server，它為Kafka Cluster提供了協(xié)調(diào)服務(wù)。

使用如下命令啟動Kafka。

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

【“&”號是為了讓在后臺運行，要不還要在手動放后臺或者重新開啟一個終端窗口?！?/p>

在Kafka 服務(wù)器啟動后，將看到如下輸出：

$ 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

…………………………………………….

…………………………………………….