了解好kafka的基礎(chǔ)概念之后，可以開始動(dòng)手，

成都創(chuàng)新互聯(lián)從2013年成立，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項(xiàng)目網(wǎng)站制作、做網(wǎng)站網(wǎng)站策劃，項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個(gè)夢想脫穎而出為使命，1280元海豐做網(wǎng)站,已為上家服務(wù),為海豐各地企業(yè)和個(gè)人服務(wù),聯(lián)系電話:13518219792

環(huán)境：centos7,

官方教程

http://kafka.apache.org/quickstart#quickstart_download

安裝java環(huán)境,安裝jdk(推薦，也省事）

Centos ：

yum -y update

yum -y install java

Ubuntu ：

sudo apt-get update

sudo apt-get install java

或者也可以通過源碼手動(dòng)安裝（如果上面的執(zhí)行了，這一步到重啟環(huán)境變量，可以直接跳過了）

http://download.oracle.com/otn-pub/java/jdk/8u131-b11/d54c1d3a095b4ff2b6607d096fa80163/jdk-8u131-linux-x64.tar.gz

tar zxvf jdk-8u65-linux-x64.tar.gz

mv jdk1.8.0_65 java

mv java /java

#設(shè)置環(huán)境變量，生效

vi .bash_profile

JAVA_HOME=/java

PATH=$PATH:$JAVA_HOME/bin

export JAVA_HOME PATH

#重新啟動(dòng)環(huán)境變量，使配置生效

source .bash_profile

下載kafka

https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.2.0/kafka_2.11-0.10.2.0.tgz

> tar -xzf kafka_2.11-0.10.2.0.tgz

> cd kafka_2.11-0.10.2.0

啟動(dòng)zookeeper服務(wù)

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

#可以通過ps aux | grep zookeeper

查看起來沒有

#編輯kafka配置變量，幾個(gè)重要的設(shè)置

vim config/server.properties
num.partitions = 10   #設(shè)置partitions數(shù)量，在客戶端消費(fèi)時(shí)指定多少個(gè)線程并發(fā)
listeners=PLAINTEXT://192.168.1.200:9092     #設(shè)置本機(jī)的監(jiān)聽ip及端口，如果為127.0.0.1那從其他機(jī)器上將連接不了，需要把192.168.1.200(我的ip)設(shè)置成你自己本機(jī)的真實(shí)ip
#設(shè)置日志的保存時(shí)間，是按byt保存還是按照時(shí)間，超過的會(huì)自動(dòng)刪除
log.retention.bytes=1073741824
log.retention.hours=168
zookeeper.connect=localhost:2181#本地監(jiān)聽的zookeeper端口，默認(rèn)即可

啟動(dòng)kafka

bin/kafka-server-start.sh config/server.properties

vim /etc/iptables.startup

#增加

-A KAFKA -p tcp -m tcp --dport 10050 -j ACCEPT

#重啟，生效

iptables-restore < /etc/iptables.startup

#查看list

iptables -L

#設(shè)置完成后在本地telnet下本機(jī)的10050通么，通的話再從其他機(jī)器telnet測試下

#如果需要重啟kafka或者zookeeper，執(zhí)行下面kill命令，再重新執(zhí)行上面啟動(dòng)命令就可以了

ps -ef | grep kafka |awk '{print $2}'|xargs kill -9

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

當(dāng)前文章：kafka-2安裝實(shí)戰(zhàn)篇-創(chuàng)新互聯(lián)
本文路徑：http://aaarwkj.com/article14/hcgde.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站維護(hù)、電子商務(wù)、軟件開發(fā)、搜索引擎優(yōu)化、網(wǎng)站營銷、自適應(yīng)網(wǎng)站

廣告

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