如何使用Kafka單節(jié)點(diǎn)搭建一個(gè)偽分布式集群？針對(duì)這個(gè)問題，這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問題的小伙伴找到更簡(jiǎn)單易行的方法。

作為一家“創(chuàng)意+整合+營(yíng)銷”的成都網(wǎng)站建設(shè)機(jī)構(gòu)，我們?cè)跇I(yè)內(nèi)良好的客戶口碑。創(chuàng)新互聯(lián)提供從前期的網(wǎng)站品牌分析策劃、網(wǎng)站設(shè)計(jì)、網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站、創(chuàng)意表現(xiàn)、網(wǎng)頁(yè)制作、系統(tǒng)開發(fā)以及后續(xù)網(wǎng)站營(yíng)銷運(yùn)營(yíng)等一系列服務(wù)，幫助企業(yè)打造創(chuàng)新的互聯(lián)網(wǎng)品牌經(jīng)營(yíng)模式與有效的網(wǎng)絡(luò)營(yíng)銷方法,創(chuàng)造更大的價(jià)值。

Kafka集群搭建分為單節(jié)點(diǎn)的偽分布式集群和多節(jié)點(diǎn)的分布式集群兩種，首先來看一下單節(jié)點(diǎn)偽分布式集群安裝。單節(jié)點(diǎn)偽分布式集群是指集群由一臺(tái)ZooKeeper服務(wù)器和一臺(tái)Kafka broker服務(wù)器組成，如下圖所示：

為了搭建單節(jié)點(diǎn)Kafka集群，需要依次安裝如下軟件：安裝Java-->安裝ZooKeeper-->安裝Kafka。

一、安裝Java

可以參考linux安裝jdk,來進(jìn)行安裝

二、安裝ZooKeeper

下載地址：https://www-us.apache.org/dist/zookeeper/stable/

下載二進(jìn)制壓縮包 zookeeper-3.4.14.tar.gz ，然后上傳到linux服務(wù)器指定目錄下，本次上傳目錄為 /software ，然后執(zhí)行如下命令安裝：

tar -zxvf zookeeper-3.4.14.tar.gz
mv zookeeper-3.4.14 /usr/local/zookeeper
cd /usr/local/zookeeper/conf
mv zoo_sample.cfg zoo.cfg
mkdir /usr/local/zookeeper/data

然后修改 zoo.cfg 文件，設(shè)置參數(shù)：

tickTime=2000
dataDir=/usr/local/zookeeper/data
clientPort=2181

進(jìn)入 zookeeper的bin目錄下，即 /usr/local/zookeeper/bin/ 目錄下，執(zhí)行命令 ./zkServer.sh start 啟動(dòng)zookeeper服務(wù)器，看到如下回顯信息則證明zookeeper啟動(dòng)成功:

[root@192 bin]# ./zkServer.sh start
ZooKeeper JMX enabled by default
Using config: /usr/local/zookeeper/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
[root@192 bin]#

三、安裝單節(jié)點(diǎn)Kafka集群

下載地址：http://kafka.apache.org/downloads.html

目前新版本是2.2.0,本次下載2.1.1版本的安裝包 kafka_2.12-2.1.1.tgz ,其中2.12代表編譯Kafka的Scala語(yǔ)言版本，2.1.1表示Kafka的版本。然后上傳壓縮包到服務(wù)器指定目錄，本次上傳目錄為 /software ，然后執(zhí)行以下命令進(jìn)行安裝:

tar -zxvf kafka_2.12-2.1.1.tgz
mv kafka_2.12-2.1.1 /usr/local/kafka
mkdir /usr/local/kafka/logs
cd /usr/local/kafka/config

編輯本目錄下的 server.properties 文件，修改如下配置：

log.dirs=/usr/local/kafka/logs

保存修改后，進(jìn)入 /usr/local/kafka/bin/ 目錄下，使用命令使用命令 ./kafka-server-start.sh -daemon ../config/server.properties 進(jìn)行啟動(dòng)， -daemon 參數(shù)表示后臺(tái)啟動(dòng)，使用 ps -ef|grep kafka 驗(yàn)證kafka進(jìn)程是否啟動(dòng)。

通過上面三步，單節(jié)點(diǎn)偽分布式集群就已經(jīng)搭建完成了，下一篇我們將搭建多節(jié)點(diǎn)分布式集群。

關(guān)于如何使用Kafka單節(jié)點(diǎn)搭建一個(gè)偽分布式集群?jiǎn)栴}的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識(shí)。

本文名稱：如何使用Kafka單節(jié)點(diǎn)搭建一個(gè)偽分布式集群-創(chuàng)新互聯(lián)
本文URL：http://weahome.cn/article/icdcd.html