Kafka代理在启动时不可用

Question

我在集群的ubuntu节点上设置了一个kafka 0.11.0.0实例。直到几周前，一切都正常工作，今天我尝试启动它，在启动后出现以下错误：

[2017-09-11 16:21:13,894] INFO [Kafka Server 0], started (kafka.server.KafkaServer)
[2017-09-11 16:21:18,998] WARN Connection to node 0 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2017-09-11 16:21:21,991] WARN Connection to node 0 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
... and so on...

我的服务器。特性：

############################# Server Basics #############################

# The id of the broker. This must be set to a unique integer for each broker.
broker.id=0

# Switch to enable topic deletion or not, default value is false
delete.topic.enable=true

############################# Socket Server Settings ##########################$

# The address the socket server listens on. It will get the value returned from
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
#listeners=PLAINTEXT://9092

# Hostname and port the broker will advertise to producers and consumers. If no$
# it uses the value for "listeners" if configured.  Otherwise, it will use the $
# returned from java.net.InetAddress.getCanonicalHostName().
advertised.listeners=PLAINTEXT://hidden_ip:55091

我编辑了广告。侦听器，因为存在将请求重定向到代理的代理。无论如何，直到几周前一切都很好。。。

我开始Kafka的步骤：

1- service zookeeper start 
2- ./kafka_2.11-0.11.0.0/bin/kafka-server-start.sh ~/kafka_2.11-0.11.0.0/config/server.properties

有什么建议吗？谢谢你们

Answer 1

当我们开始搜索日志以查找错误的实际原因时，我们遇到了同样的情况。

当我们启动Kafka集群时，它默认使用

listeners=PLAINTEXT://:9092

无法连接，无法找到主机。

我们把线路改为

listeners=PLAINTEXT://<our ip address> :9092,

然后

listeners=PLAINTEXT://<our ip address> :9093, 

在我们的server-1.properties（另一个代理id文件）中，我们在其他server.properties文件中复制并重新启动群集。

Answer 2

我也有同样的问题...

所以我先问动物园管理员一些数据

echo dump | nc localhost 2181

我得到了这样的东西

SessionTracker dump:
Session Sets (3):
0 expire at Sun Dec 03 18:15:48 GST 2017:
0 expire at Sun Dec 03 18:15:51 GST 2017:
1 expire at Sun Dec 03 18:15:54 GST 2017:
0x1601c9a25190000
ephemeral nodes dump:
Sessions with Ephemerals (1):
0x1601c9a25190000:
/controller
/brokers/ids/0

我理解这意味着我有1个可用的代理-它的id为0。

所以，让我们找到那个经纪人。

bin/zookeeper-shell.sh localhost:2181 <<< "get /brokers/ids/0"

而我看到

{"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://192.168.1.220:9092"],"jmx_port":-1,"host":"192.168.1.220","timestamp":"1512308520781","port":9092,"version":4}
cZxid = 0x69
ctime = Sun Dec 03 17:42:00 GST 2017
mZxid = 0x69
mtime = Sun Dec 03 17:42:00 GST 2017
pZxid = 0x69
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x1601c9a25190000
dataLength = 196
numChildren = 0

这让我相当吃惊...//192.168.1.220:9092，所以当我把连接字符串改为

bin/kafka-console-producer.sh  --broker-list PLAINTEXT://192.168.1.220:9092  --topic test

现在一切都成功了。

祝你好运

Answer 3

取消注释此行

把这个改成了