cimpl.KafkaException: KafkaError{code=_INVALID_ARG，val=-186，str=“无此类配置属性："bootstrap_servers""}

Question

我正试图通过python生产者脚本为Kafka主题生成AVRO数据，我已经安装了python依赖项avro-python 3和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""}

经过调查，我发现我应该安装(libsasl2-dev和libsasl2 2-模块)依赖关系。(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下面

Answer 1

所显示的错误与OS包无关。

它是bootstrap.servers，不是带下划线的。同样，Kafka模块使用连字符，而不是下划线。

Docs - https://docs.confluent.io/kafka-clients/python/current/overview.html

您还可以使用pip安装fastavro。