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 集群機器上來回通訊導致問題，所以這個時候需要切換成內(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)文章
IDEA設(shè)置生成帶注釋的getter和setter的圖文教程
通常我們用idea默認生成的getter和setter方法是不帶注釋的，當然，我們同樣可以設(shè)置idea像MyEclipse一樣生成帶有Javadoc的模板，具體設(shè)置方法，大家參考下本文2018-05-05
深入理解JSON及其在Java中的應(yīng)用小結(jié)
json它是一種輕量級的數(shù)據(jù)交換格式,由于其易于閱讀和編寫,同時也易于機器解析和生成,因此廣泛應(yīng)用于網(wǎng)絡(luò)數(shù)據(jù)交換和配置文件,這篇文章主要介紹了深入理解JSON及其在Java中的應(yīng)用,需要的朋友可以參考下2023-12-12
MyBatis-Plus中AutoGenerator的使用案例
AutoGenerator是MyBatis-Plus的代碼生成器，通過?AutoGenerator?可以快速生成?Pojo、Mapper、?Mapper?XML、Service、Controller?等各個模塊的代碼，這篇文章主要介紹了MyBatis-Plus中AutoGenerator的詳細使用案例,需要的朋友可以參考下2023-05-05
大根堆是每個結(jié)點的值不大于他的父親結(jié)點的值；小根堆是每個結(jié)點的值不小于他的父親結(jié)點的值。本文將利用完全二叉樹創(chuàng)建大根堆和小根堆，感興趣的可以了解一下2022-08-08
重新啟動IDEA時maven項目SSM框架文件變色所有@注解失效
這篇文章主要介紹了重新啟動IDEA時maven項目SSM框架文件變色所有@注解失效，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-03-03
詳解SpringMVC學習系列（6） 之 數(shù)據(jù)驗證
這篇文章主要介紹了詳解SpringMVC學習系列（6） 之 數(shù)據(jù)驗證 ,具有一定的參考價值，感興趣的小伙伴們可以參考一下。2016-12-12
SpringBoot訪問web中的靜態(tài)資源的方式小結(jié)
這篇文章主要介紹了SpringBoot訪問web中的靜態(tài)資源的方式,本文給大家介紹了兩種方式,通過代碼示例和圖文講解的非常詳細,具有一定的參考價值,需要的朋友可以參考下2024-10-10
這篇文章主要介紹了Java多線程中的單例模式兩種實現(xiàn)方式的相關(guān)資料,需要的朋友可以參考下2017-04-04
這篇文章主要為大家詳細介紹了Springboot實現(xiàn)全局時間格式化的四種常見方式,文中的示例代碼講解詳細,感興趣的小伙伴可以跟隨小編一起學習一下2023-12-12
spring boot搭建文件服務(wù)器解決同時上傳多個圖片和下載的問題
這篇文章主要介紹了spring boot搭建文件服務(wù)器解決同時上傳多個圖片和下載的問題,本文給大家介紹的非常詳細，具有一定的參考借鑒價值，需要的朋友可以參考下2019-11-11