如何解决使用 kafka-python 在 kerberos 安全的 Kafka 集群上生产
我有 truststore.jks
和 password
。我已将其转换为 truststore.pem
。这包含 CA 证书。
我正在使用:
producer = KafkaProducer(bootstrap_servers=kafka_bootstrap_server_ssl,security_protocol='SASL_SSL',sasl_kerberos_service_name='kafka')
但是我找不到指向 jks 和密码的属性。我试过 ssl_cafile,ssl_password 但它给出的错误是 NoBrokersAvailable
。
这里用python实现和连接kerberos kafka的方法是什么?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。