在 python 中为 Kafka 代理指定 SSL 详细信息答案

【问题标题】：Specify SSL details for Kafka brokers in python在 python 中为 Kafka 代理指定 SSL 详细信息
【发布时间】：2018-07-18 09:21:38
【问题描述】：

我需要连接到具有多个 SSL 代理的 kafka 实例。我正在使用 kafka-python 来消费和处理数据。

我看到了他们使用 kafka-python 通过 SSL 连接到单个代理的链接。

链接：http://maximilianchrist.com/python/databases/2016/08/13/connect-to-apache-kafka-from-python-using-ssl.html

具体代码

consumer = KafkaConsumer(bootstrap_servers='my.server.com',
                          security_protocol='SSL',
                          ssl_check_hostname=True,
                          ssl_cafile='CARoot.pem',
                          ssl_certfile='certificate.pem',
                          ssl_keyfile='key.pem')

既然有多个broker，我需要知道如何在构造函数中指定多个ssl_ca、ssl_cert、ssl_key？？

【问题讨论】：

标签： python-3.x ssl apache-kafka kafka-python

【解决方案1】：

应设置 SSL，以便客户端可以通过您的任何代理进行身份验证。我建议您查看本教程以更好地了解 SSL 基础知识https://docs.confluent.io/current/kafka/encryption.html#kafka-ssl-encryption

【讨论】：