
- Apache Kafka 教程
- Apache Kafka - 首頁
- Apache Kafka - 簡介
- Apache Kafka - 基礎知識
- Apache Kafka - 叢集架構
- Apache Kafka - 工作流程
- Apache Kafka - 安裝步驟
- Apache Kafka - 基本操作
- 簡單生產者示例
- 消費者組示例
- 與 Storm 整合
- 與 Spark 整合
- 即時應用(Twitter)
- Apache Kafka - 工具
- Apache Kafka - 應用
- Apache Kafka 有用資源
- Apache Kafka - 快速指南
- Apache Kafka - 有用資源
- Apache Kafka - 討論
Apache Kafka - 安裝步驟
以下是您機器上安裝 Java 的步驟。
步驟 1 - 驗證 Java 安裝
希望您現在已經在機器上安裝了 Java,因此您可以使用以下命令進行驗證。
$ java -version
如果您的機器上成功安裝了 Java,您將看到已安裝 Java 的版本。
步驟 1.1 - 下載 JDK
如果未下載 Java,請訪問以下連結下載最新版本的 JDK,並下載最新版本。
http://www.oracle.com/technetwork/java/javase/downloads/index.html現在最新版本是 JDK 8u 60,檔名為“jdk-8u60-linux-x64.tar.gz”。請將檔案下載到您的機器上。
步驟 1.2 - 解壓縮檔案
通常,下載的檔案儲存在下載資料夾中,請驗證並使用以下命令解壓縮 tar 安裝程式。
$ cd /go/to/download/path $ tar -zxf jdk-8u60-linux-x64.gz
步驟 1.3 - 移動到 Opt 目錄
為了使所有使用者都能使用 Java,請將解壓縮的 Java 內容移動到 usr/local/java
/ 資料夾。
$ su password: (type password of root user) $ mkdir /opt/jdk $ mv jdk-1.8.0_60 /opt/jdk/
步驟 1.4 - 設定路徑
要設定路徑和 JAVA_HOME 變數,請將以下命令新增到 ~/.bashrc 檔案中。
export JAVA_HOME =/usr/jdk/jdk-1.8.0_60 export PATH=$PATH:$JAVA_HOME/bin
現在將所有更改應用到當前執行的系統中。
$ source ~/.bashrc
步驟 1.5 - Java 備選方案
使用以下命令更改 Java 備選方案。
update-alternatives --install /usr/bin/java java /opt/jdk/jdk1.8.0_60/bin/java 100
步驟 1.6 − 現在使用步驟 1 中說明的驗證命令 (java -version) 驗證 Java。
步驟 2 - ZooKeeper 框架安裝
步驟 2.1 - 下載 ZooKeeper
要在您的機器上安裝 ZooKeeper 框架,請訪問以下連結並下載最新版本的 ZooKeeper。
http://zookeeper.apache.org/releases.html截至目前,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 - 建立配置檔案
使用命令 vi “conf/zoo.cfg” 開啟名為 conf/zoo.cfg
的配置檔案,並將所有以下引數設定為起點。
$ vi conf/zoo.cfg tickTime=2000 dataDir=/path/to/zookeeper/data clientPort=2181 initLimit=5 syncLimit=2
配置檔案儲存成功並返回終端後,您可以啟動 zookeeper 伺服器。
步驟 2.4 - 啟動 ZooKeeper 伺服器
$ bin/zkServer.sh start
執行此命令後,您將收到如下所示的響應 -
$ 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 伺服器,並收到以下響應。
Connecting to localhost:2181 ................ ................ ................ Welcome to ZooKeeper! ................ ................ WATCHER:: WatchedEvent state:SyncConnected type: None path:null [zk: localhost:2181(CONNECTED) 0]
步驟 2.6 - 停止 Zookeeper 伺服器
連線伺服器並執行所有操作後,您可以使用以下命令停止 zookeeper 伺服器 -
$ bin/zkServer.sh stop
現在您已在機器上成功安裝了 Java 和 ZooKeeper。讓我們看看安裝 Apache Kafka 的步驟。
步驟 3 - Apache Kafka 安裝
讓我們繼續執行以下步驟以在您的機器上安裝 Kafka。
步驟 3.1 - 下載 Kafka
要在您的機器上安裝 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 將下載到您的機器上。
步驟 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
現在您已在機器上下載了最新版本的 Kafka。
步驟 3.3 - 啟動伺服器
您可以透過執行以下命令啟動伺服器 -
$ bin/kafka-server-start.sh config/server.properties
伺服器啟動後,您將在螢幕上看到以下響應 -
$ 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 - 停止伺服器
執行所有操作後,您可以使用以下命令停止伺服器 -
$ bin/kafka-server-stop.sh config/server.properties
現在我們已經討論了 Kafka 的安裝,我們可以在下一章學習如何在 Kafka 上執行基本操作。