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

chrisdrew1 gravatar image

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': Can't initialize writer: com.streamsets.pipeline.lib.util.SchemaRegistryException: java.util.concurrent.ExecutionException: PKIX path building failed: unable to find valid certification path to requested target

edit retag flag offensive close merge delete