カフカブローカーは開始時に利用できません

私はクラスタの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編集ブローカに要求をリダイレクトするプロキシが存在するためです。

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

はどれアドバイス：とにかく、いくつかの数週間前まではすべてが

...カフカを開始するために私のステップをうまく働きましたか？はありがとう

出典

2017-09-11 Andrea Giordano

/usr/local/kafka/bin/kafka-console-producer.sh --brokerリストはlocalhost：9092 --topic test_log1

SSS [2017年9月26日10 ：55：22,687] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：22,738] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：22,789] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：22,889] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：22,940] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,041] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,091] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,142] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,242] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,343] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,394] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,495] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,545] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,646] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,697] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,747] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,848] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：23,949] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients。 [2017-09-26 10：55：24,050] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：24,150] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：24,251] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：24,302] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：24,352] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） [2017-09-26 10：55：24,403] WARNノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります。（org.apache.kafka.clients.NetworkClient） ^ Z [4] +停止/usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost：9092 --topic test_log1

出典

2017-09-26 10:58:15

警告していないと、それは私が同じ問題を抱えているすべてうまく動作します –

私はserver.propertes：

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
私はあなたが私が実行しようとget.and同じように同じエラーが出ます：

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

うまく動作しますが、エラーは発生しません。
だから私はあなたがポートkafkaサーバーused.Thisポートがesestablishedされていないか間違ったIPを接続していないときにチェックする必要がありますと思う。
PS：同じマシンでこれを実行します。

出典

2017-09-27 09:26:08 AlexYu

私も同じ問題を持っていた...

だから私は、私は戻って、この

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

ような何かを得る

echo dump | nc localhost 2181

飼育係にいくつかのデータを尋ねることから始めます私が1ブローカーを利用できることを意味するためにこれを読んでください - それは0のidを持っています。

だから、そのブローカーについて見つけることができます。

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

これはすべて悪いd。

幸運！

出典

2017-12-03 14:22:16

私はkafkaサーバーを設定しました。プロパティーのリスナーはlisteners=PLAINTEXT://**10.127.96.151**:9092

となりますが、私はコンシューマに./kafka-console-consumer.sh --bootstrap-server **localhost**:9092 --topic topic1 --from-beginningと要求しますが、WARNをバーストします。

私は10.127.96.151として、消費者のブートストラップ・サーバーを修正する場合：9092これ以上は

出典

2018-01-08 03:09:48 touchstone

カフカブローカーは開始時に利用できません

答えて

関連する問題