Closed bhaktinarvekar closed 4 years ago
Received the following error:
Traceback (most recent call last): File "app.py", line 21, in consumer = KafkaConsumer("data-post") File "C:\Users\Bhakti\Documents\SGA_Peer_Review_Project\Yoda\DataPostProcess\env\lib\site-packages\kafka\consumer\group.py", line 354, in init self._client = KafkaClient(metrics=self._metrics, **self.config) File "C:\Users\Bhakti\Documents\SGA_Peer_Review_Project\Yoda\DataPostProcess\env\lib\site-packages\kafka\client_async.py", line 240, in init self.config['api_version'] = self.check_version(timeout=check_timeout) File "C:\Users\Bhakti\Documents\SGA_Peer_Review_Project\Yoda\DataPostProcess\env\lib\site-packages\kafka\client_async.py", line 926, in check_version raise Errors.NoBrokersAvailable() kafka.errors.NoBrokersAvailable: NoBrokersAvailable
Received the following error:
Traceback (most recent call last): File "app.py", line 21, in
consumer = KafkaConsumer("data-post")
File "C:\Users\Bhakti\Documents\SGA_Peer_Review_Project\Yoda\DataPostProcess\env\lib\site-packages\kafka\consumer\group.py", line 354, in init
self._client = KafkaClient(metrics=self._metrics, **self.config)
File "C:\Users\Bhakti\Documents\SGA_Peer_Review_Project\Yoda\DataPostProcess\env\lib\site-packages\kafka\client_async.py", line 240, in init
self.config['api_version'] = self.check_version(timeout=check_timeout)
File "C:\Users\Bhakti\Documents\SGA_Peer_Review_Project\Yoda\DataPostProcess\env\lib\site-packages\kafka\client_async.py", line 926, in check_version
raise Errors.NoBrokersAvailable()
kafka.errors.NoBrokersAvailable: NoBrokersAvailable