Description
Description
Hi,
Could anyone please help me or shed some light on the below?
I'm getting the content of certificate file (ca.crt file ) from the environment variable key.
Could anyone let me know whether there is any config parameter available that can take the file content as value (something similar to ssl.certificate.pem and ssl.key.pem) ? I see only ssl.ca.location in the Producer config.
Since, I get the crt content as an environment variable, I'm unable to use the ssl.ca.location .
Also, I need to create a file with the content that I get from the environment variable key and save it to use ssl.ca.location.
Thanks in advance!
Example :
config = { 'bootstrap.servers':bootstrap_server, 'security.protocol':security_protocol, 'ssl_check_hostname':True, 'ssl.ca.location':os.environ['KAFKA_NET_CERT'], # Not working as expecting the ca.crt file path. 'ssl.certificate.pem':os.environ['KAFKA_NET_TLS_CERT'], 'ssl.key.pem':os.environ['KAFKA_NET_TLS_KEY'] }