我需要使用 SSL 连接到具有多个代理的 kafka 实例。 我正在使用 kafka-python 来消费和处理数据。
我看到他们使用 kafka-python 通过 SSL 连接到单个代理的链接。
具体代码
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_ca、ssl_cert、ssl_key ??
最佳答案
应设置 SSL,以便客户端可以通过您的任何代理进行身份验证。我建议您查看本教程以更好地了解 SSL 基础知识 https://docs.confluent.io/current/kafka/encryption.html#kafka-ssl-encryption
关于python-3.x - 在 python 中为 Kafka 代理指定 SSL 详细信息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51398235/