在我們的Openshift生態系統中,我們有一個來自wurstmeister/kafka
的卡夫卡實例。截至目前,我能夠有withing使用下面的參數Openshift
系統訪問的卡夫卡,讓卡夫卡與ip以及服務名稱相連 - Openshift
KAFKA_LISTENERS=PLAINTEXT://:9092
KAFKA_ADVERTISED_HOST_NAME=kafka_service_name
而且ofcourse,港口和zookeper的PARAMS是存在的。
我可以從openshift系統中的pod訪問kafka。但是我無法從主機訪問kafka服務。 Eventhough我能夠使用它的IP,並能使用遠程登錄莢訪問卡夫卡莢,telnet Pod_IP 9092
當我試圖用卡夫卡生產者從主機,我收到以下錯誤連接,
2017年8月7日07:45:13925] WARN錯誤,同時用 相關性id 2獲取的元數據:{tls21 = LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
而當我嘗試從主機上的Kafka客戶端連接使用IP,它是空白的。
注:截至目前,它是一個單一的openshift服務器。用例用於開發測試。
「主機」是什麼意思? OpenShift集羣的主節點?你的個人機器,如果在Minishift或oc下運行這個機器羣集? –
@GrahamDumpleton現在只有一個Openshift。用例用於開發測試。 – Kannan
這並不能幫助我理解你在說什麼主機。如果您使用非HTTP協議與其進行通信,爲了在集羣外部訪問以進行測試,可以使用「oc端口轉發」。否則,您需要使用其中一種方法來配置服務/端口在羣集外部可見。 –