2017-09-22 9 views
0

私は開発を開始するために、Mac Pro(Sierra; 10.12.6)でローカルにカフカを実行しています。私は、ZooKeeperのとカフカサーバ(0.11.0.1)を開始しました:シンプルなカフカプロデューサーのトラブル

bin/zookeeper-server-start.sh config/zookeeper.properties 
bin/kafka-server-start.sh config/server.properties 

私が作成したトピックを持っている:

bin/kafka-topics.sh --list --zookeeper localhost:2181 
__consumer_offsets 
access 
my-topic 

(さ__consumer_offsetsかわからない、私は、他の2つを作成しました)。

私はkafka-python(1.3.4)をインストールしました。 私のサンプルプログラムは死んでシンプルです:

from kafka import KafkaProducer 

producer = KafkaProducer(bootstrap_servers=['localhost:9092']) 
producer.send('my-topic', 'Another message') 

しかし、それは、次のようなメッセージでcroaks:

Traceback (most recent call last): 
    File "produce.py", line 3, in <module> 
    producer = KafkaProducer(bootstrap_servers=['localhost:9092']) 
    File "/Library/Python/2.7/site-packages/kafka/producer/kafka.py", line 347, in __init__ 
    **self.config) 
    File "/Library/Python/2.7/site-packages/kafka/client_async.py", line 220, in __init__ 
    self.config['api_version'] = self.check_version(timeout=check_timeout) 
    File "/Library/Python/2.7/site-packages/kafka/client_async.py", line 861, in check_version 
    raise Errors.NoBrokersAvailable() 
kafka.errors.NoBrokersAvailable: NoBrokersAvailable 

のアイデア?どんな援助も感謝します

+0

を使用して、ホスト名の解決は、いくつかの他のホスト名を与えている可能性があるかもしれない... –

+0

はい - configファイルに変更が加えられました。ありがとう! – Rob

+0

kafkaブローカーが実際に9092で動作しているかどうかを調べることができます。 'kafka-console-producer.sh --broker-list localhost-9092 --topic my-topic'を実行して、ブローカーインスタンスが本当に稼働しているかどうかを確認してください。 kafka-startを実行すると、kafkaインスタンスが実行されているポートとURLを確認することができます。 –

答えて

0

server.configファイル advertised.listeners=PLAINTEXT://your.host.name:9092に設定があることを確認してください。

は、他のあなたの問題を解決したものを共有することができ、デフォルトでカフカは、あなたが、私が提案し何を試してみましたjava.net.InetAddress.getCanonicalHostName()

関連する問題