快捷導(dǎo)航

kafka內(nèi)外網(wǎng)訪問(wèn)配置方式

更新時(shí)間：2023年09月16日 09:15:28 作者：飄然渡滄海

這篇文章主要介紹了kafka內(nèi)外網(wǎng)訪問(wèn)配置方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

kafka

kafka里面兩種監(jiān)聽(tīng)配置

內(nèi)網(wǎng)監(jiān)聽(tīng)配置

listeners=PLAINTEXT://192.168.0.213:9092

配置完內(nèi)網(wǎng)可以正常得去消費(fèi)或者添加kfka數(shù)據(jù)

如果配置了 advertised.listeners 就無(wú)法正常訪問(wèn)消費(fèi)

advertised.listeners=PLAINTEXT://101.89.163.1:9092

WARN [Consumer clientId=consumer-console-consumer-94880-1, groupId=console-consumer-94880] Error while fetching metadata with correlation id 2 : {ooxx=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

因?yàn)槲业耐饩W(wǎng)通訊雖然注冊(cè)得zookeeper里面了，但是外網(wǎng)網(wǎng)絡(luò)無(wú)法在kafka 集群機(jī)器上來(lái)回通訊導(dǎo)致問(wèn)題，所以這個(gè)時(shí)候需要切換成內(nèi)外網(wǎng)分流訪問(wèn)

內(nèi)外網(wǎng)分流

方法1

listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
listeners=INTERNAL://192.168.0.213:9092,EXTERNAL://192.168.0.213:19092
advertised.listeners=INTERNAL://192.168.0.213:9092,EXTERNAL://101.89.163.9:19092
inter.broker.listener.name=INTERNAL

方法2

listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
listeners=INTERNAL://192.168.0.213:9092,EXTERNAL://101.89.163.9:19092
advertised.listeners=INTERNAL://192.168.0.213:9092,EXTERNAL://101.89.163.9:19092
inter.broker.listener.name=INTERNAL

注意這兩的區(qū)別是listeners的EXTERNAL使用的ip不一樣，一個(gè)使用內(nèi)網(wǎng)ip，一個(gè)使用外網(wǎng)ip。

如果你的kafka宿主機(jī)有外網(wǎng)網(wǎng)卡，只能用外網(wǎng)ip，若使用配置1，kafka通過(guò)listeners監(jiān)聽(tīng)的兩個(gè)端口都是內(nèi)網(wǎng)網(wǎng)卡的數(shù)據(jù)，無(wú)法接收到外網(wǎng)網(wǎng)卡數(shù)據(jù)；
如果你的kafka宿主機(jī)外網(wǎng)ip是映射來(lái)的，只能使用內(nèi)網(wǎng)ip，原因也是上面說(shuō)過(guò)的，不存在外網(wǎng)網(wǎng)卡，kafka啟動(dòng)監(jiān)聽(tīng)就會(huì)報(bào)錯(cuò)，而使用內(nèi)網(wǎng)ip有環(huán)境配置好的轉(zhuǎn)發(fā)，可以接收到外網(wǎng)ip的數(shù)據(jù)。

在這里配置得 kafka內(nèi)部訪問(wèn)端口與外部訪問(wèn)端口不能是一致得。

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

Java多線程編程之Lock用法實(shí)例
這篇文章主要介紹了Java多線程編程之Lock用法實(shí)例,本文直接給出代碼實(shí)例,需要的朋友可以參考下
2015-05-05
PowerJob的DatabaseMonitorAspect源碼流程
這篇文章主要為大家介紹了PowerJob的DatabaseMonitorAspect源碼流程解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
2024-01-01
hibernate 中 fetch=FetchType.LAZY 懶加載失敗處理方法
這篇文章主要介紹了hibernate 中 fetch=FetchType.LAZY 懶加載失敗處理方法,需要的朋友可以參考下
2017-09-09
mybatis插入數(shù)據(jù)后返回自增主鍵ID的兩種實(shí)現(xiàn)方式
這篇文章主要介紹了mybatis插入數(shù)據(jù)后返回自增主鍵ID的兩種實(shí)現(xiàn)方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
2024-05-05
java中Object類(lèi)4種方法詳細(xì)介紹
大家好，本篇文章主要講的是java中Object類(lèi)4種方法詳細(xì)介紹，感興趣的同學(xué)趕快來(lái)看一看吧，對(duì)你有幫助的話記得收藏一下，方便下次瀏覽
2022-01-01
java注解@Override用法舉例詳解
這篇文章主要介紹了java注解@Override用法的相關(guān)資料,@Override?是Java中的一個(gè)注解,用于表明一個(gè)方法重寫(xiě)了父類(lèi)或接口中的方法,它可以幫助編譯器檢查方法簽名是否正確,避免拼寫(xiě)錯(cuò)誤或參數(shù)列表不一致導(dǎo)致的低級(jí)錯(cuò)誤,需要的朋友可以參考下
2024-12-12
詳解java動(dòng)態(tài)代理模式
這篇文章主要為大家詳細(xì)介紹了java動(dòng)態(tài)代理模式，總結(jié)一下代理模式，以及jdk,cglib代理模式用法，來(lái)理解代理模式，感興趣的小伙伴們可以參考一下
2016-02-02
JVM?運(yùn)行時(shí)數(shù)據(jù)區(qū)與JMM?內(nèi)存模型
這篇文章主要介紹了JVM?運(yùn)行時(shí)數(shù)據(jù)區(qū)與JMM?內(nèi)存模型，文章圍繞主題展開(kāi)詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值。需要的朋友可以參考一下
2022-07-07
spring使用xml方式整合Druid數(shù)據(jù)源連接池
傳統(tǒng)的JDBC數(shù)據(jù)庫(kù)連接方式,每次連接都需加載Connection到內(nèi)存并驗(yàn)證,使用后再放回,從而重復(fù)利用數(shù)據(jù)庫(kù)連接資源,這不僅降低了系統(tǒng)資源消耗,還避免了頻繁連接導(dǎo)致的服務(wù)器崩潰和內(nèi)存泄漏風(fēng)險(xiǎn),數(shù)據(jù)庫(kù)連接池在初始化時(shí)創(chuàng)建并保持最小數(shù)量的數(shù)據(jù)庫(kù)連接
2024-10-10
idea如何自動(dòng)生成serialVersionUID
這篇文章主要介紹了idea如何自動(dòng)生成serialVersionUID,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2020-02-02