Can't connect to broker using TLS #4642
Unanswered
joenferreira
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
Hi all, I'm quite new at using this library in conjunction with confluent kafka python. I have an envrioment in JAVA KAFKA - in which i'm able to successfuly connect to the broker and I want to do the same thing on the python client. For JAVA KAFKA i created a .csr and have a .key too. The CSR was signed and i received back the ca.pem and another .pem file. I then used these files to create a .p12 file and from that the keystore file and the truststore file. In Java client I'm running the following command:
kafka-console-consumer.sh --bootstrap-server xxxx:9193 --topic gtest --group testgroup--consumer-property 'security.protocol=SSL' --consumer-property 'sasl.mechanism=SCRAM-SHA-512' --consumer-property 'ssl.truststore.location=x_trust.jks' --consumer-property 'ssl.keystore.location=x_key.jks' --consumer-property 'ssl.keystore.password=*****' --consumer-property 'ssl.truststore.type=JKS' --consumer-property 'ssl.truststore.password=****' --from-beginning
and it works fine. As far as I know, librdkafka client I can't use these .jks files, so how to i get on to connect using python? I've tried using the .p12 in librdkafka as keystore + password but doesn't work :(
Any help is appreaciated!
Beta Was this translation helpful? Give feedback.
All reactions