confluentinc / confluentinc/confluent-kafka-python

Certificate Param in Config

Open
#977 2 comments 4 reactions 0 assignees View on GitHub
component:librdkafka component:schema-registry enhancement status:waiting-for-interest workaround
Dominant language
Python
Stars
509
Forks
964
Avg merge
2d 2h
Merged PRs (30d)
14

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']
}`

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.