Linux中如何安裝Kafka分布式集群-創(chuàng)新互聯(lián)

這篇文章主要介紹Linux中如何安裝Kafka分布式集群,文中介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們一定要看完!

專注于為中小企業(yè)提供網(wǎng)站建設(shè)、網(wǎng)站設(shè)計服務(wù),電腦端+手機端+微信端的三站合一,更高效的管理,為中小企業(yè)永城免費做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都,凝聚了一批互聯(lián)網(wǎng)行業(yè)人才,有力地推動了上千多家企業(yè)的穩(wěn)健成長,幫助中小企業(yè)通過網(wǎng)站建設(shè)實現(xiàn)規(guī)模擴充和轉(zhuǎn)變。

Kafka(http://kafka.apache.org/) 是由 LinkedIn 使用 Scala 編寫的一個分布式消息系統(tǒng),用作 LinkedIn 的活動流(Activity Stream)和運營數(shù)據(jù)處理管道(Pipeline)的基礎(chǔ),具有高水平擴展和高吞吐量。Spack、Elasticsearch 都支持與 Kafka 集成。下面看一下幾種分布式開源消息隊列系統(tǒng)的對比:

Linux中如何安裝Kafka分布式集群

Kafka 集群架構(gòu):

Linux中如何安裝Kafka分布式集群

一般不建議直接使用 Kafka 自帶的 Zookeeper 建立 zk 集群,這里我們使用獨立的 zk 集群,zk 集群搭建參考文章 Linux下ZooKeeper分布式集群安裝。

這里 Linux 選擇 CentOS 7.2。

# cd /usr/local
# mkdir kafka
# cd kafka
# wget -P /usr/local/kafka http://mirror.bit.edu.cn/apache/kafka/1.0.0/kafka_2.11-1.0.0.tgz
# tar -zxvf kafka_2.11-1.0.0.tgz
# mkdir kafka-logs

# cd kafka_2.11-1.0.0/config
# vim server.properties

編輯配置文件 (配置項可以參考 http://kafka.apache.org/documentation.html#brokerconfigs) 為:

# 唯一標識,0開始
broker.id=0

# 服務(wù)器端口和ip
port=9092
host.name=192.168.2.20
# 日志數(shù)據(jù)保存的目錄
log.dirs=/usr/local/kafka/kafka-logs

log.retention.hours=168
# 每條消息能夠容納的大大小,默認1000012
message.max.bytes=5242880
# 默認的副本因子,即保存消息的副本數(shù),默認1
default.replication.factor=2
# 取消息的大直接數(shù),默認1048576
replica.fetch.max.bytes=5242880

# 配置zk地址
zookeeper.connect=192.168.20.11:2181,192.168.20.12:2181,192.168.20.13:2181

啟動 Kafka 之前需啟動 Zookeeper,然后啟動 Kafka,各個節(jié)點需單獨啟動:

# cd /usr/local/kafka/kafka_2.11-1.0.0/bin
# ./kafka-server-start.sh -daemon ../config/server.properties //后臺啟動服務(wù)
# jps       //查看服務(wù)是否啟動成功
# ./kafka-server-stop.sh  //關(guān)閉服務(wù)

最后我們在三臺不同的服務(wù)器上各部署一個 Kafka 進程,以構(gòu)成一個 Kafka 集群。

以上是“Linux中如何安裝Kafka分布式集群”這篇文章的所有內(nèi)容,感謝各位的閱讀!希望分享的內(nèi)容對大家有幫助,更多相關(guān)知識,歡迎關(guān)注創(chuàng)新互聯(lián)成都網(wǎng)站設(shè)計公司行業(yè)資訊頻道!

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn,海內(nèi)外云服務(wù)器15元起步,三天無理由+7*72小時售后在線,公司持有idc許可證,提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢,專為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

當(dāng)前名稱:Linux中如何安裝Kafka分布式集群-創(chuàng)新互聯(lián)
URL鏈接:http://muchs.cn/article26/sppcg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供企業(yè)網(wǎng)站制作網(wǎng)站營銷、全網(wǎng)營銷推廣關(guān)鍵詞優(yōu)化、域名注冊、App設(shè)計

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

網(wǎng)站建設(shè)網(wǎng)站維護公司