2017-03-11 11 views
1

私は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 
+0

このコードはサンドボックスまたはマシンで実行していますか?後者の場合、__sandbox.hortonworks.com__はサンドボックス外から解決できないという問題があります。 –

答えて

0

、あなたは直接apacheのカフカダウンロードしてローカルで実行することができます。

以下のフォローは、あなたがsandbox.hortonworks.com:9092でカフカブローカーにアクセスすることができないよう

ダウンロード https://kafka.apache.org/downloads

クイックスタート https://kafka.apache.org/quickstart

0

がサウンドにリンクします。私はsandbox.hortonworks.comを解決できるように、サンドボックスVMのIPをホストファイルに追加することをお勧めします

関連する問題