How do I make a non-ssl schema registry connection while using ssl to connect to brokers in my pipeline.?

asked 2020-07-07 13:16:39 -0500

Oracle cdc > avro schema gen > kafka producer

I can create a valid pipeline that works great with a non-ssl kafka cluster. When using it against a ssl kafka cluster where the brokers are ssl and schema registry is not, I get the following error. I figure this is most likely due to that fact that it's trying to connect to schema registry in a SSL manner? What parameter is there to get this to work?

KAFKA_51 - Error serializing record ' 0x000138.00167e99.01a0 ::8': java.io.IOException: Can't initialize writer: com.streamsets.pipeline.lib.util.SchemaRegistryException: java.util.concurrent.ExecutionException: javax.net.ssl.SSLHandshakeException: sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target

edit retag flag offensive close merge delete