無法從遠程客戶端連接到數字海洋上的kafka服務器

Question

我試圖測試從一個環境連接到運行我們的kafka服務器的數字海洋拖放的連接。

我試圖運行./kafka-console-producer.sh --broker-list <HOST_NAME>:9092 --topic <topic>

而且我一直獲得迄今所採取

[2017-10-17 14:38:59,438] WARN Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2017-10-17 14:38:59,490] WARN Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2017-10-17 14:38:59,542] WARN Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2017-10-17 14:38:59,644] WARN Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) [2017-10-17 14:38:59,696] WARN Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) 

步驟：

• 設置advertised.listeners到PLAINTEXT://<ipaddress>:9092
• 添加到每個試圖連接的客戶端的/ etc/hosts
• 添加advertised.host和advertised.port
• 9092被接受的數字滄海一粟
• 卡夫卡的IPv4，而不是IPv6的

我的服務器的有關章節運行Ubuntu的安裝裏面的TCP連接的.properties文件（HOST_NAME是一個別名爲實際的主機名來保護隱私）：

listeners=PLAINTEXT://HOST_NAME:9092 
host.name=HOST_NAME 
# Hostname and port the broker will advertise to producers and consumers. If not set, 
# it uses the value for "listeners" if configured. Otherwise, it will use the value 
# returned from java.net.InetAddress.getCanonicalHostName(). 
advertised.listeners=PLAINTEXT://HOST_NAME:9092 
advertised.host.name=HOST_NAME 
advertised.port=9092 

我可以從LOCALMACHINE將自己連接的，但我在我的繩子結束瞭如何獲得一個啞巴小測試我懸掛在電線上。

我在做什麼錯？

Answer 1

這是解決通過修改iptables的加入此規則，以我的iptables的配置我的遠程主機上的配置：

-A INPUT -s [hosts went here] -p tcp -m state --state NEW -m tcp --dport 9092 -j ACCEPT 

我只好允許遠程主機上的端口9092的TCP連接。我們的基礎設施團隊阻止了我們的開發環境中的所有特定端口，這阻止了使用telnet的開發。

總結：使用iptable配置打開遠程kafka服務器上的端口。確認您的本地主機可以發送tcp連接數據到該端口。