以下是在您的機器上安裝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.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。
下面繼續以下步驟來安裝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上執行基本操作。