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
-
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