search

wbarnha / kafka-python-ng

Fork for Python client for Apache Kafka
https://wbarnha.github.io/kafka-python-ng/
Apache License 2.0
81 stars 11 forks source link

NoBrokersAvailable #65

Open wbarnha opened 8 months ago

wbarnha commented 8 months ago

While trying to run the producer I keep on getting this issue, I have tried adding api_version to the code but its not working. Can anybody help

Traceback (most recent call last): File "C:/Users/Aditya Anand/Nudity_detection-on-Live-Video-Stream/consumer.py", line 12, in consumer = KafkaConsumer( File "C:\Users\Aditya Anand\AppData\Local\Programs\Python\Python38\lib\site-packages\kafka\consumer\group.py", line 356, in init self._client = KafkaClient(metrics=self._metrics, **self.config) File "C:\Users\Aditya Anand\AppData\Local\Programs\Python\Python38\lib\site-packages\kafka\client_async.py", line 244, in init self.config['api_version'] = self.check_version(timeout=check_timeout) File "C:\Users\Aditya Anand\AppData\Local\Programs\Python\Python38\lib\site-packages\kafka\client_async.py", line 927, in check_version raise Errors.NoBrokersAvailable() kafka.errors.NoBrokersAvailable: NoBrokersAvailable

Process finished with exit code 1

truonglac2603 commented 2 months ago

Facing the same issue. I'm using 3 domains for KAFKA_BROKER, don't know if this is the problem or not