在python中指定kafka代理的ssl详细信息

r8xiu3jd  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(532)

我需要连接到Kafka示例,其中有多个代理与ssl。我正在使用kafkapython来消费和处理数据。
我看到了他们使用kafkapython通过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')

我需要知道,因为有多个代理如何指定多个ssl\u ca,ssl\u cert,ssl\u密钥在构造函数??

h79rfbju

h79rfbju1#

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

相关问题