私はkafkaを初めて使用しています。私はHortonworks Sandboxのサンプルプログラムを試しています。 以下のエラーが発生します。どんな助けもありがとう。HortonworksのApache kafkaエラー
from kafka import KafkaProducer
from kafka.errors import KafkaError
producer = KafkaProducer(bootstrap_servers=['sandbox.hortonworks.com:9092'])
topic = "kafkatopic"
producer.send(topic, b'test message')
エラー:カフカを探索するの
Traceback (most recent call last):
File "kaf_prod.py", line 4, in <module>
producer = KafkaProducer(bootstrap_servers=['sandbox.hortonworks.com:9092'])
File "/usr/lib/python2.6/site-packages/kafka/producer/kafka.py", line 334, in __init__
**self.config)
File "/usr/lib/python2.6/site-packages/kafka/client_async.py", line 204, in __init__
self.config['api_version'] = self.check_version(timeout=check_timeout)
File "/usr/lib/python2.6/site-packages/kafka/client_async.py", line 795, in check_version
raise Errors.NoBrokersAvailable()
kafka.errors.NoBrokersAvailable: NoBrokersAvailable
このコードはサンドボックスまたはマシンで実行していますか?後者の場合、__sandbox.hortonworks.com__はサンドボックス外から解決できないという問題があります。 –