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.properties:

############################# 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

我编辑了advertised.listeners,因为有一个代理将请求重定向到代理.无论如何直到几周前一切都很好......

我开始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

我也有同样的问题......

所以我首先向Zookeeper询问一些数据

__CODE__

我得到这样的东西

__CODE__

我读到这意味着我有1个Broker可用 - 并且它的id为0.

所以,让我们找一下那个经纪人.

__CODE__

我明白了

__CODE__

这让我大吃一惊... PLAINTEXT://192.168.1.220:9092,所以当我改变我的连接字符串来读

__CODE__

现在一切都奏效了.

祝好运 !!

Answer 2

取消注释此行

listeners = PLAINTEXT：//：9092

改成

listeners = PLAINTEXT：//127.0.0.1：9092

Answer 3

当我们开始在日志中搜索错误的实际原因时,我们遇到了同样的情况.

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

listeners=PLAINTEXT://:9092

连接,但无法找到主机.

我们将线路改为

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

然后

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

在我们的server-1.properties(另一个代理id文件)中,我们在其他server.properties文件中复制并重新启动了我们的集群.

Answer 4

我将 kafka server.properties 的监听器配置为listeners=PLAINTEXT://**10.127.96.151**:9092

但我请求消费者为./kafka-console-consumer.sh --bootstrap-server **localhost**:9092 --topic topic1 --from-beginning，然后它会爆发警告。

当我将消费者引导服务器修复为10.127.96.151 :9092 时，它运行良好，没有更多警告

Answer 5

我的服务器属性：

listeners=PLAINTEXT://hidden_ip:9092

当我运行时：
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic lt1 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic lt1
我得到同样的错误，就像你得到的一样。我尝试运行：

bin/kafka-console-producer.sh --broker-list hidden_ip:9092 --topic lt1

它有效，我没有收到任何错误。
所以我认为你应该检查kafka服务器使用的端口是什么。当端口未建立或连接错误的IP时会出现此错误。
PS：我在同一台机器上运行这个。