欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

kafka內外網訪問配置方式

 更新時間：2023年09月16日 09:15:28   作者：飄然渡滄海  
這篇文章主要介紹了kafka內外網訪問配置方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

kafka

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

內網監(jiān)聽配置

listeners=PLAINTEXT://192.168.0.213:9092

配置完內網可以正常得去消費或者添加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)

因為我的外網通訊雖然注冊得zookeeper里面了，但是外網網絡無法在kafka 集群機器上來回通訊導致問題，所以這個時候需要切換成內外網分流訪問

內外網分流

方法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不一樣，一個使用內網ip，一個使用外網ip。

  • 如果你的kafka宿主機有外網網卡，只能用外網ip，若使用配置1，kafka通過listeners監(jiān)聽的兩個端口都是內網網卡的數(shù)據(jù)，無法接收到外網網卡數(shù)據(jù)；
  • 如果你的kafka宿主機外網ip是映射來的，只能使用內網ip，原因也是上面說過的，不存在外網網卡，kafka啟動監(jiān)聽就會報錯，而使用內網ip有環(huán)境配置好的轉發(fā)，可以接收到外網ip的數(shù)據(jù)。

在這里配置得 kafka內部訪問端口與外部訪問端口不能是一致得。

總結

以上為個人經驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

相關文章

  • Java多線程編程之Lock用法實例

    Java多線程編程之Lock用法實例

    這篇文章主要介紹了Java多線程編程之Lock用法實例,本文直接給出代碼實例,需要的朋友可以參考下
    2015-05-05
  • PowerJob的DatabaseMonitorAspect源碼流程

    PowerJob的DatabaseMonitorAspect源碼流程

    這篇文章主要為大家介紹了PowerJob的DatabaseMonitorAspect源碼流程解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
    2024-01-01
  • hibernate 中 fetch=FetchType.LAZY 懶加載失敗處理方法

    hibernate 中 fetch=FetchType.LAZY 懶加載失敗處理方法

    這篇文章主要介紹了hibernate 中 fetch=FetchType.LAZY 懶加載失敗處理方法,需要的朋友可以參考下
    2017-09-09
  • mybatis插入數(shù)據(jù)后返回自增主鍵ID的兩種實現(xiàn)方式

    mybatis插入數(shù)據(jù)后返回自增主鍵ID的兩種實現(xiàn)方式

    這篇文章主要介紹了mybatis插入數(shù)據(jù)后返回自增主鍵ID的兩種實現(xiàn)方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-05-05
  • java中Object類4種方法詳細介紹

    java中Object類4種方法詳細介紹

    大家好，本篇文章主要講的是java中Object類4種方法詳細介紹，感興趣的同學趕快來看一看吧，對你有幫助的話記得收藏一下，方便下次瀏覽
    2022-01-01
  • java注解@Override用法舉例詳解

    java注解@Override用法舉例詳解

    這篇文章主要介紹了java注解@Override用法的相關資料,@Override?是Java中的一個注解,用于表明一個方法重寫了父類或接口中的方法,它可以幫助編譯器檢查方法簽名是否正確,避免拼寫錯誤或參數(shù)列表不一致導致的低級錯誤,需要的朋友可以參考下
    2024-12-12
  • 詳解java動態(tài)代理模式

    詳解java動態(tài)代理模式

    這篇文章主要為大家詳細介紹了java動態(tài)代理模式，總結一下代理模式，以及jdk,cglib代理模式用法，來理解代理模式，感興趣的小伙伴們可以參考一下
    2016-02-02
  • JVM?運行時數(shù)據(jù)區(qū)與JMM?內存模型

    JVM?運行時數(shù)據(jù)區(qū)與JMM?內存模型

    這篇文章主要介紹了JVM?運行時數(shù)據(jù)區(qū)與JMM?內存模型，文章圍繞主題展開詳細的內容介紹，具有一定的參考價值。需要的朋友可以參考一下
    2022-07-07
  • spring使用xml方式整合Druid數(shù)據(jù)源連接池

    spring使用xml方式整合Druid數(shù)據(jù)源連接池

    傳統(tǒng)的JDBC數(shù)據(jù)庫連接方式,每次連接都需加載Connection到內存并驗證,使用后再放回,從而重復利用數(shù)據(jù)庫連接資源,這不僅降低了系統(tǒng)資源消耗,還避免了頻繁連接導致的服務器崩潰和內存泄漏風險,數(shù)據(jù)庫連接池在初始化時創(chuàng)建并保持最小數(shù)量的數(shù)據(jù)庫連接
    2024-10-10
  • idea如何自動生成serialVersionUID

    idea如何自動生成serialVersionUID

    這篇文章主要介紹了idea如何自動生成serialVersionUID,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-02-02

最新評論