traceback.txt

INFO:pykafka.producer:Worker exited for broker emmett-debian:9092
ERROR:pykafka.producer:Exception encountered in worker thread:
  File "/home/emmett/git/parsely/pykafka/pykafka/producer.py", line 438, in queue_reader
    self.producer._send_request(batch, self)
  File "/home/emmett/git/parsely/pykafka/pykafka/producer.py", line 366, in _send_request
    self._update()
  File "/home/emmett/git/parsely/pykafka/pykafka/producer.py", line 201, in _update
    self._cluster.update()
  File "/home/emmett/git/parsely/pykafka/pykafka/cluster.py", line 382, in update
    metadata = self._get_metadata()
  File "/home/emmett/git/parsely/pykafka/pykafka/cluster.py", line 287, in _get_metadata
    'Unable to connect to a broker to fetch metadata. See logs.')

INFO:pykafka.producer:Blocking until all messages are sent
Traceback (most recent call last):
  File "../notes/kafka_producer_test.py", line 41, in <module>
    time.sleep(1)
  File "/home/emmett/git/parsely/pykafka/pykafka/producer.py", line 184, in __exit__
    self.stop()
  File "/home/emmett/git/parsely/pykafka/pykafka/producer.py", line 234, in stop
    self._wait_all()
  File "/home/emmett/git/parsely/pykafka/pykafka/producer.py", line 398, in _wait_all
    self._raise_worker_exceptions()
  File "/home/emmett/git/parsely/pykafka/pykafka/producer.py", line 169, in _raise_worker_exceptions
    raise ex
RuntimeError: Unable to connect to a broker to fetch metadata. See logs