We are testing the new TLS configuration in our Kafka Clusters in Test Environment, and we have two types of consumers on using librdkafka
and other using Kafka Consumers in Scala.
security.protocol=SSL
ssl.endpoint.identification.algorithm=none
enable.ssl.certificate.verification=false
This work fine with our kafkacat
, and also our libraries with librdkafka
.
But if I try to connect with our Scala connector the configuration enable.ssl.certificate.verification
doesn't exists in the documentation
I would like to know what is the equivalent of enable.ssl.certificate.verification
in the Kafka consumers in Scala or Java. This is just to proceed with our testing. Is there anyway to connect with SSL without the certificate using the Scala Library?