kafka內(nèi)外網(wǎng)訪問配置方式
kafka
kafka里面兩種監(jiān)聽配置
內(nèi)網(wǎng)監(jiān)聽配置
listeners=PLAINTEXT://192.168.0.213:9092
配置完內(nèi)網(wǎng)可以正常得去消費或者添加kfka數(shù)據(jù)
如果配置了 advertised.listeners 就無法正常訪問消費
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)
因為我的外網(wǎng)通訊雖然注冊得zookeeper里面了，但是外網(wǎng)網(wǎng)絡(luò)無法在kafka 集群機器上來回通訊導(dǎo)致問題，所以這個時候需要切換成內(nèi)外網(wǎng)分流訪問
內(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不一樣，一個使用內(nèi)網(wǎng)ip，一個使用外網(wǎng)ip。
- 如果你的kafka宿主機有外網(wǎng)網(wǎng)卡，只能用外網(wǎng)ip，若使用配置1，kafka通過listeners監(jiān)聽的兩個端口都是內(nèi)網(wǎng)網(wǎng)卡的數(shù)據(jù)，無法接收到外網(wǎng)網(wǎng)卡數(shù)據(jù)；
- 如果你的kafka宿主機外網(wǎng)ip是映射來的，只能使用內(nèi)網(wǎng)ip，原因也是上面說過的，不存在外網(wǎng)網(wǎng)卡，kafka啟動監(jiān)聽就會報錯，而使用內(nèi)網(wǎng)ip有環(huán)境配置好的轉(zhuǎn)發(fā)，可以接收到外網(wǎng)ip的數(shù)據(jù)。
在這里配置得 kafka內(nèi)部訪問端口與外部訪問端口不能是一致得。
總結(jié)
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了Java多線程編程之Lock用法實例,本文直接給出代碼實例,需要的朋友可以參考下2015-05-05
PowerJob的DatabaseMonitorAspect源碼流程
這篇文章主要為大家介紹了PowerJob的DatabaseMonitorAspect源碼流程解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2024-01-01
hibernate 中 fetch=FetchType.LAZY 懶加載失敗處理方法
這篇文章主要介紹了hibernate 中 fetch=FetchType.LAZY 懶加載失敗處理方法,需要的朋友可以參考下2017-09-09
mybatis插入數(shù)據(jù)后返回自增主鍵ID的兩種實現(xiàn)方式
這篇文章主要介紹了mybatis插入數(shù)據(jù)后返回自增主鍵ID的兩種實現(xiàn)方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-05-05
大家好，本篇文章主要講的是java中Object類4種方法詳細介紹，感興趣的同學(xué)趕快來看一看吧，對你有幫助的話記得收藏一下，方便下次瀏覽2022-01-01
這篇文章主要介紹了java注解@Override用法的相關(guān)資料,@Override?是Java中的一個注解,用于表明一個方法重寫了父類或接口中的方法,它可以幫助編譯器檢查方法簽名是否正確,避免拼寫錯誤或參數(shù)列表不一致導(dǎo)致的低級錯誤,需要的朋友可以參考下2024-12-12
這篇文章主要為大家詳細介紹了java動態(tài)代理模式，總結(jié)一下代理模式，以及jdk,cglib代理模式用法，來理解代理模式，感興趣的小伙伴們可以參考一下2016-02-02
JVM?運行時數(shù)據(jù)區(qū)與JMM?內(nèi)存模型
這篇文章主要介紹了JVM?運行時數(shù)據(jù)區(qū)與JMM?內(nèi)存模型，文章圍繞主題展開詳細的內(nèi)容介紹，具有一定的參考價值。需要的朋友可以參考一下2022-07-07
spring使用xml方式整合Druid數(shù)據(jù)源連接池
傳統(tǒng)的JDBC數(shù)據(jù)庫連接方式,每次連接都需加載Connection到內(nèi)存并驗證,使用后再放回,從而重復(fù)利用數(shù)據(jù)庫連接資源,這不僅降低了系統(tǒng)資源消耗,還避免了頻繁連接導(dǎo)致的服務(wù)器崩潰和內(nèi)存泄漏風(fēng)險,數(shù)據(jù)庫連接池在初始化時創(chuàng)建并保持最小數(shù)量的數(shù)據(jù)庫連接2024-10-10
這篇文章主要介紹了idea如何自動生成serialVersionUID,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-02-02