Traceback (most recent call last):


 "D:\Anaconda\lib\site-packages\jedi\inference\compiled\subprocess\__init__.py", line 261, in _send

is_exception, traceback, result = pickle_load(self._get_process().stdout)


 "D:\Anaconda\lib\site-packages\jedi\_compatibility.py", line 396, in pickle_load

return pickle.load(file, encoding='bytes')
EOFError: Ran out of input

Traceback (most recent call last):


 "<stdin>", line 1, in <module>


 "/opt/project/test-kafka-1/lib/python3.7/site-packages/pykafka/client.py", line 142, in __init__

broker_version=broker_version)


 "/opt/project/test-kafka-1/lib/python3.7/site-packages/pykafka/cluster.py", line 215, in __init__

self.update()


 "/opt/project/test-kafka-1/lib/python3.7/site-packages/pykafka/cluster.py", line 518, in update

metadata = self._get_metadata()


 "/opt/project/test-kafka-1/lib/python3.7/site-packages/pykafka/cluster.py", line 305, in _get_metadata

'Unable to connect to a broker to fetch metadata. See logs.')
pykafka.exceptions.NoBrokersAvailableError: Unable to connect to a broker to fetch metadata. See logs.
