cimpl.KafkaException:KafkaError{code=_INVALID_ARG,val= -186,str =“没有这样的配置属性:“引导服务器””}

k7fdbhmy  于 2022-11-28  发布在  Apache
关注(0)|答案(1)|浏览(236)

我试图通过python生产者脚本产生Kafka主题的AVRO数据,我已经安装了python依赖项avro-python3和confluent_kafka,但是当运行此脚本时,我得到了以下错误:

File "./kafka_producer_avro.py", line 24, in <module>
    kafka_producer_obj = Producer(kafka_config_obj)
cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "bootstrap_servers""}

经过调查,我发现我应该安装(libsasl 2-dev和libsasl 2-modules)依赖项。(sudo yum install gcc libffi-devel python-devel python-pip python-wheel openssl-devel libsasl2-devel openldap-devel),但我得到了Error: Unable to find a match: python-devel python-pip python-wheel libsasl2-devel以下

svdrlsy4

svdrlsy41#

您显示的错误与操作系统软件包无关。
它是bootstrap.servers,没有下划线,而且Kafka模块是连字符,没有下划线。
文件-https://docs.confluent.io/kafka-clients/python/current/overview.html
您还可以使用pip安装fastavro

相关问题