저는 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__은 샌드 박스 외부에서 확인할 수없는 문제 일 수 있습니다. –