快捷導(dǎo)航

Kafka單節(jié)點(diǎn)偽分布式集群搭建實(shí)現(xiàn)過程詳解

更新時(shí)間：2020年11月11日 14:36:34 作者：碼農(nóng)大衛(wèi)

這篇文章主要介紹了Kafka單節(jié)點(diǎn)偽分布式集群搭建實(shí)現(xiàn)過程詳解,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

　　Kafka集群搭建分為單節(jié)點(diǎn)的偽分布式集群和多節(jié)點(diǎn)的分布式集群兩種，首先來看一下單節(jié)點(diǎn)偽分布式集群安裝。單節(jié)點(diǎn)偽分布式集群是指集群由一臺ZooKeeper服務(wù)器和一臺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 啟動zookeeper服務(wù)器，看到如下回顯信息則證明zookeeper啟動成功:

[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語言版本，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)行啟動， -daemon 參數(shù)表示后臺啟動，使用 ps -ef|grep kafka 驗(yàn)證kafka進(jìn)程是否啟動。

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

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: