I have truststore.jks
and password
. I have converted this into truststore.pem
. This contains the ca certs.
I am using:
producer = KafkaProducer(bootstrap_servers=kafka_bootstrap_server_ssl,
security_protocol='SASL_SSL',
sasl_kerberos_service_name='kafka')
But I cant find the property to point jks and password. I tried ssl_cafile, ssl_password but it gives error as NoBrokersAvailable
.
What is the way to achieve and connect here with kerberos kafka using python?
question from:
https://stackoverflow.com/questions/65939195/produce-on-kerberos-secured-kafka-cluster-using-kafka-python 与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…