Schema Registry Config SslCaLocation doesn't work

[sanderrhorst]

Duplicate of 2140 which has been closed already.

I am running my client on windows machine. I try to run my producer where schema registry endpoint is signed by private CA. My truststore contains the root CA and intermediate of that server certificate, but its not working at all. Where as, when I add the root CA to the truststore of my windows system, it works without issues.

So this is clearly indicating that the SchemaRegistryConfig class is not properly picking up the SslCaLocation property.

Please implement a fix for this or tell me if there is a workaround for this.

Error log:

Starting producer, Ctrl-C to stop producing
Unhandled exception. Confluent.Kafka.ProduceException2[Avro.Generic.GenericRecord,Avro.Generic.GenericRecord]: System.Net.Http.HttpRequestException: [https://schemaEndpoint/] HttpRequestException: The SSL connection could not be established, see inner exception. at Confluent.SchemaRegistry.RestService.ExecuteOnOneInstanceAsync(Func1 createRequest)
at Confluent.SchemaRegistry.RestService.RequestAsync[T](String endPoint, HttpMethod method, Object[] jsonBody)
at Confluent.SchemaRegistry.RestService.GetLatestSchemaAsync(String subject)
at Confluent.SchemaRegistry.CachedSchemaRegistryClient.GetLatestSchemaAsync(String subject)
at Confluent.SchemaRegistry.AsyncSerde1.GetReaderSchema(String subject, Schema schema) at Confluent.SchemaRegistry.Serdes.GenericSerializerImpl.Serialize(String topic, Headers headers, GenericRecord data, Boolean isKey) at Confluent.SchemaRegistry.Serdes.GenericSerializerImpl.SerializeAsync(GenericRecord value, SerializationContext context) at Confluent.SchemaRegistry.Serdes.AvroSerializer1.SerializeAsync(T value, SerializationContext context)
at Confluent.Kafka.SyncOverAsync.SyncOverAsyncSerializer1.Serialize(T data, SerializationContext context) at Confluent.Kafka.Producer2.Produce(TopicPartition topicPartition, Message2 message, Action1 deliveryHandler)
---> System.Net.Http.HttpRequestException: [https://schemaEndpoint/] HttpRequestException: The SSL connection could not be established, see inner exception.
at Confluent.SchemaRegistry.RestService.ExecuteOnOneInstanceAsync(Func1 createRequest) at Confluent.SchemaRegistry.RestService.RequestAsync[T](String endPoint, HttpMethod method, Object[] jsonBody) at Confluent.SchemaRegistry.RestService.GetLatestSchemaAsync(String subject) at Confluent.SchemaRegistry.CachedSchemaRegistryClient.GetLatestSchemaAsync(String subject) at Confluent.SchemaRegistry.AsyncSerde1.GetReaderSchema(String subject, Schema schema)
at Confluent.SchemaRegistry.Serdes.GenericSerializerImpl.Serialize(String topic, Headers headers, GenericRecord data, Boolean isKey)
at Confluent.SchemaRegistry.Serdes.GenericSerializerImpl.SerializeAsync(GenericRecord value, SerializationContext context)
at Confluent.SchemaRegistry.Serdes.AvroSerializer1.SerializeAsync(T value, SerializationContext context) at Confluent.Kafka.SyncOverAsync.SyncOverAsyncSerializer1.Serialize(T data, SerializationContext context)
at Confluent.Kafka.Producer2.Produce(TopicPartition topicPartition, Message2 message, Action1 deliveryHandler) --- End of inner exception stack trace --- at Confluent.Kafka.Producer2.Produce(TopicPartition topicPartition, Message2 message, Action1 deliveryHandler)
at Confluent.Kafka.Producer2.Produce(String topic, Message2 message, Action`1 deliveryHandler)
at kafka_client_ssl_avro_producer_generic.Program.RunProducer(ProducerConfig producerConfig, SchemaRegistryConfig schemaRegistryConfig, String topicName) in C:\Projects\archive\dotnet-native-kafka-examples\axual-client-dotnet-examples-master\kafka\kafka-client-avro-producer-generic\Program.cs:line 124