完整报错：

Traceback (most recent call last):File "/Applications/PyCharm.app/Contents/plugins/python/helpers/pydev/pydevd.py", line 1483, in _execpydev_imports.execfile(file, globals, locals)  # execute the scriptFile "/Applications/PyCharm.app/Contents/plugins/python/helpers/pydev/_pydev_imps/_pydev_execfile.py", line 18, in execfileexec(compile(contents+"\n", file, 'exec'), glob, loc)File "/Users/xq/Desktop/data/pycharm_pro/Test_alg/python_kafka/generator.py", line 11, in <module>producer = KafkaProducer(bootstrap_servers='localhost:1234')File "/Users/xq/.conda/envs/pycharm_env/lib/python3.8/site-packages/kafka/producer/kafka.py", line 381, in __init__client = KafkaClient(metrics=self._metrics, metric_group_prefix='producer',File "/Users/xq/.conda/envs/pycharm_env/lib/python3.8/site-packages/kafka/client_async.py", line 244, in __init__self.config['api_version'] = self.check_version(timeout=check_timeout)File "/Users/xq/.conda/envs/pycharm_env/lib/python3.8/site-packages/kafka/client_async.py", line 900, in check_versionraise Errors.NoBrokersAvailable()
kafka.errors.NoBrokersAvailable: NoBrokersAvailable

解决方法

在初始化的时候传入api的版本，即：
修改：

producer = KafkaProducer(bootstrap_servers='localhost:1234')

为

producer = KafkaProducer(bootstrap_servers='localhost:1234', api_version=(0, 10, 2))

这个版本对应自己的kafka版本，一个比较安全的值是：0.10.2，更多版本信息可以参考：https://cwiki.apache.org/confluence/display/KAFKA/Compatibility+Matrix

问题解析

python-kafka并不会给太多报错的细节，所以这需要我们查看报错位置，这里的报错：

    self.config['api_version'] = self.check_version(timeout=check_timeout)

可知是api_version的报错，因此我们只需查看相关资料，即可得到解决方案

解决python-kafka连接kafka时报错kafka.errors.NoBrokersAvailable: NoBrokersAvailable相关推荐

python如何读取log文件_怎么解决Python读取log文件时报错
怎么解决Python读取log文件时报错发布时间:2020-05-23 14:15:56 来源:亿速云阅读:157 作者:鸽子问题描述: 写了一个读取log文件的Python脚本:# -*- c ...
解决ubuntu中连接mysql时报错：Access denied for user ‘root‘@‘localhost‘
在ubuntu安装好mysql后无脑的跟着别人的博客配置了远程访问的权限,然后在连接时报错: itcast@itcast-virtual-machine:/usr/share/mysql$ mysql ...
PyCharm远程连接（linux）python解释器导入pyspark时报错：No module named ‘pyspark‘
PyCharm远程连接(linux)python解释器导入pyspark时报错:No module named 'pyspark' ,并且from pyspark import SparkConf, ...
python 调用 tensorflow.dll_解决windows上安装tensorflow时报错,“DLL load failed: 找不到指定的模块”的问题...
最近打算开始研究一下机器学习,今天在windows上装tensorflow花了点功夫,其实前面的步骤不难,只要依次装好python3.5,numpy,tensorflow就行了,有一点要注意的是目前只 ...
解决vscode进行chrome调试时报错：localhost拒绝了我们的连接请求
解决vscode进行chrome调试时报错:localhost拒绝了我们的连接请求只是为了记录,参考博客https://blog.csdn.net/LiBlacksmith/article/deta ...
mysql第二天无法连接_MySQL第二天早上第一次连接超时报错，解决方法com.mysql.jdbc.exceptions.jdbc4.CommunicationsException:...
http://zeusami.iteye.com/blog/1112827 MySQL第二天早上第一次连接超时报错,解决方法com.mysql.jdbc.exceptions.jdbc4.Commun ...
解决安装python3.7.2时报错Setup failed,0x80072f7d-未指定的错误
解决安装python3.7.2时报错Setup failed,0x80072f7d-未指定的错误之前win7安装过python,很顺利的安装成功.但是系统升级后再次安装就安装不上了,总是报错,百度了 ...
连接mysql时报错：The driver has not received any packets from the server.
连接mysql时报错. 前几天可以打开的数据库也不能打开,报java.net.ConnectException: Connection refused: connect.错误. 报错原因:mysql服 ...
解决ThinkPHP关闭调试模式时报错的问题汇总
解决ThinkPHP关闭调试模式时报错的问题汇总参考文章: (1)解决ThinkPHP关闭调试模式时报错的问题汇总 (2)https://www.cnblogs.com/ZDPPU/p/584881 ...
解决MySQL删除外键时报错Error Code: 1091. Can‘t DROP ‘XXX‘； check that column/key exists
解决MySQL删除外键时报错Error Code: 1091. Can't DROP 'XXX'; check that column/key exists 长期不写基础的 MySQL 代码,笔者 ...

解决python-kafka连接kafka时报错kafka.errors.NoBrokersAvailable: NoBrokersAvailable

解决方法

问题解析

解决python-kafka连接kafka时报错kafka.errors.NoBrokersAvailable: NoBrokersAvailable相关推荐

最新文章

热门文章