(1)第一句話=========
KAFKA_LISTENERS:負責(zé)綁定網(wǎng)卡
KAFKA_ADVERTISED_LISTENERS:負責(zé)發(fā)布外網(wǎng)地址,這個地址會發(fā)布到zookeeper中。
(2)第二句話========
內(nèi)網(wǎng)部署的程序,讀的地址是KAFKA_LISTENERS寫的。
外網(wǎng)部署的程序,讀的地址是KAFKA_ADVERTISED_LISTENERS
zookeeper中存的地址是KAFKA_ADVERTISED_LISTENERS配置的,多個kafka注冊到zookeeper就是把這個地址放到zookeeper中。如果不能理解的,可以用客戶端工具打開zookeeper,看一下就清楚了。
仔細回味上面這幾句話,接下來看實際例子。
(1)內(nèi)網(wǎng)訪問第一步:kafka配置0.0.0.0:9092,表示內(nèi)網(wǎng)所有網(wǎng)卡都綁定9092
第二步:程序里寫的地址就是內(nèi)網(wǎng)的地址,下圖是,172.16.3.130
(2)外網(wǎng)訪問KAFKA_CFG_LISTENERS=PLAINTEXT://0.0.0.0:9092
將kafka綁定到局域網(wǎng)所有網(wǎng)卡,當局域網(wǎng)的機器訪問的時候,直接在springboot中配置本地ip。如
以上程序,如果部署在外網(wǎng)。則需要做如下改變
第一步:KAFKA_CFG_ADVERTISED_LISTENERS配置這個。
KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://<互聯(lián)網(wǎng)ip>:9092
,這句話意思是將PLAINTEXT://<互聯(lián)網(wǎng)ip>:9092,放到zookeeper中。當外面的服務(wù)訪問到zookeeper的時候,從這個地址拿到kafka的內(nèi)容,看下圖,zookeeper中的broker-ids里存的就是這個你寫上去的地址。
第二步:springboot程序通過外網(wǎng)訪問的時候,配置 改成這樣
(1)程序首先是從zookeeper中獲取broker地址。然后用這個地址去連kafka。如果配置的地址是外網(wǎng)程序找不到的一個地址,那就連不上了。
(2)zookeeper中的地址是通過
KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://<互聯(lián)網(wǎng)ip>:9092
這個關(guān)鍵句來配置的。
你是否還在尋找穩(wěn)定的海外服務(wù)器提供商?創(chuàng)新互聯(lián)www.cdcxhl.cn海外機房具備T級流量清洗系統(tǒng)配攻擊溯源,準確流量調(diào)度確保服務(wù)器高可用性,企業(yè)級服務(wù)器適合批量采購,新人活動首月15元起,快前往官網(wǎng)查看詳情吧
文章名稱:深入理解KAFKA-創(chuàng)新互聯(lián)
分享URL:http://jinyejixie.com/article10/eicdo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供電子商務(wù)、標簽優(yōu)化、靜態(tài)網(wǎng)站、App設(shè)計、網(wǎng)站制作、云服務(wù)器
聲明:本網(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)
猜你還喜歡下面的內(nèi)容