用Python连接外部Kafka服务器的方法，不包括任何特殊字符或引号："cacerts"文件

Question

我可以用python-kafka包连接到本地kafka服务器。 但是，我无法连接到外部启用ssl的kafka服务器。你知道吗

而我的java代码能够使用以下参数与同一台服务器通信：

props.put("security.protocol", kafkaProtocol);
props.put(SslConfigs.SSL_PROTOCOL_CONFIG, kafkaProtocol);
props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, kafkaCertLocation);
props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, kafkaCertPassword);

我不知道python-kafka包中的等价参数到底是什么。 有人能马上给我一些建议吗。你知道吗

我尝试过以下代码：

producer = KafkaProducer(value_serializer=lambda m: json.dumps(m).encode('utf-8'),
                         bootstrap_servers='YYYYY.KAKFASERVER.com:9094',
                         security_protocol='SSL',
                         ssl_certfile='cacerts',
                         ssl_password='xxxxxxx')

我收到以下错误消息：

failed to connect to YYYYY.KAKFASERVER.com:9094 unknown error (_ssl.c:3715)