2017-03-11 3 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

는 소리 빠른 시작. sandbox.hortonworks.com을 해결할 수 있도록 샌드 박스 VM의 IP를 호스트 파일에 추가하는 것이 좋습니다.