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
のアイデア?どんな援助も感謝します
を使用して、ホスト名の解決は、いくつかの他のホスト名を与えている可能性があるかもしれない... –
はい - configファイルに変更が加えられました。ありがとう! – Rob
kafkaブローカーが実際に9092で動作しているかどうかを調べることができます。 'kafka-console-producer.sh --broker-list localhost-9092 --topic my-topic'を実行して、ブローカーインスタンスが本当に稼働しているかどうかを確認してください。 kafka-startを実行すると、kafkaインスタンスが実行されているポートとURLを確認することができます。 –