search

AbsaOSS / ABRiS

Avro SerDe for Apache Spark structured APIs.
Apache License 2.0
229 stars 75 forks source link

javax.net.ssl.SSLHandshakeException while using Abris v6.2.0 #293

Closed kishoreraj05 closed 2 years ago

kishoreraj05 commented 2 years ago

Spark - 3.1.2 Scala - 2.12

SchemaRegistryConfig :
map put("schema.registry.topic", "")
map put("schema.registry.url", "")
map put("schema.registry.ssl.keystore.type", "")
map put("schema.registry.ssl.keystore.certificate.chain", "")
map put("schema.registry.ssl.keystore.key", "")
map put("schema.registry.ssl.truststore.certificates", "")
map put("schema.registry.ssl.truststore.type", "")

Code Snippet:

val fromAvroConfig: FromAvroConfig = AbrisConfig
      .fromConfluentAvro
      .downloadReaderSchemaByLatestVersion
      .andTopicRecordNameStrategy(
        schemaRegistryConfig("schema.registry.topic"),
        "xxx",
        "com.expediagroup.dataplatform")
      .usingSchemaRegistry(schemaRegistryConfig("schema.registry.url"))
      .withSchemaRegistryConfig(schemaRegistryConfig.toMap)

Exception:

Message:    PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
Exception:  javax.net.ssl.SSLHandshakeException
sun.security.ssl.Alert.createSSLException(Alert.java:131)
sun.security.ssl.TransportContext.fatal(TransportContext.java:324)
sun.security.ssl.TransportContext.fatal(TransportContext.java:267)
sun.security.ssl.TransportContext.fatal(TransportContext.java:262)
sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:654)
sun.security.ssl.CertificateMessage$T12CertificateConsumer.onCertificate(CertificateMessage.java:473)
sun.security.ssl.CertificateMessage$T12CertificateConsumer.consume(CertificateMessage.java:369)
sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:377)
sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:444)
sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:422)
sun.security.ssl.TransportContext.dispatch(TransportContext.java:182)
sun.security.ssl.SSLTransport.decode(SSLTransport.java:152)
sun.security.ssl.SSLSocketImpl.decode(SSLSocketImpl.java:1392)
sun.security.ssl.SSLSocketImpl.readHandshakeRecord(SSLSocketImpl.java:1300)
sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:435)
sun.net.www.protocol.https.HttpsClient.afterConnect(HttpsClient.java:559)
sun.net.www.protocol.https.AbstractDelegateHttpsURLConnection.connect(AbstractDelegateHttpsURLConnection.java:197)
sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1567)
sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1495)
java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:480)
sun.net.www.protocol.https.HttpsURLConnectionImpl.getResponseCode(HttpsURLConnectionImpl.java:352)
io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:277)
io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:367)
io.confluent.kafka.schemaregistry.client.rest.RestService.getLatestVersion(RestService.java:893)
io.confluent.kafka.schemaregistry.client.rest.RestService.getLatestVersion(RestService.java:884)
io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getLatestSchemaMetadata(CachedSchemaRegistryClient.java:469)
za.co.absa.abris.avro.registry.AbstractConfluentRegistryClient.getLatestSchemaMetadata(AbstractConfluentRegistryClient.scala:38)
za.co.absa.abris.avro.read.confluent.SchemaManager.getSchemaMetadataBySubjectAndVersion(SchemaManager.scala:66)
za.co.absa.abris.avro.read.confluent.SchemaManager.getSchemaBySubjectAndVersion(SchemaManager.scala:55)
za.co.absa.abris.avro.read.confluent.SchemaManager.getSchema(SchemaManager.scala:46)
za.co.absa.abris.config.FromSchemaDownloadingConfigFragment.usingSchemaRegistry(Config.scala:250)
za.co.absa.abris.config.FromSchemaDownloadingConfigFragment.usingSchemaRegistry(Config.scala:245)
com.expedia.ers.security.data.dataloader.internal.utils.DataFrameUtil$.getFromAvroConfig(DataFrameUtil.scala:52)
com.expedia.ers.security.data.dataloader.internal.utils.DataFrameUtil$.applyEGSPDfSchema(DataFrameUtil.scala:30)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSource.loadEGSPStreamDF(EgspKafkaDataSource.scala:64)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSource.loadDataFrame(EgspKafkaDataSource.scala:41)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSourceTest.$anonfun$new$6(EgspKafkaDataSourceTest.scala:123)
com.expedia.ers.security.data.common.utils.SparkContextSetup.withSparkSession(SparkContextSetup.scala:18)
com.expedia.ers.security.data.common.utils.SparkContextSetup.withSparkSession$(SparkContextSetup.scala:12)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSourceTest.withSparkSession(EgspKafkaDataSourceTest.scala:25)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSourceTest.$anonfun$new$5(EgspKafkaDataSourceTest.scala:114)
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
org.scalatest.Transformer.apply(Transformer.scala:22)
org.scalatest.Transformer.apply(Transformer.scala:20)
org.scalatest.FlatSpecLike$$anon$5.apply(FlatSpecLike.scala:1682)
org.scalatest.TestSuite.withFixture(TestSuite.scala:196)
org.scalatest.TestSuite.withFixture$(TestSuite.scala:195)
org.scalatest.FlatSpec.withFixture(FlatSpec.scala:1685)
org.scalatest.FlatSpecLike.invokeWithFixture$1(FlatSpecLike.scala:1680)
org.scalatest.FlatSpecLike.$anonfun$runTest$1(FlatSpecLike.scala:1692)
org.scalatest.SuperEngine.runTestImpl(Engine.scala:286)
org.scalatest.FlatSpecLike.runTest(FlatSpecLike.scala:1692)
org.scalatest.FlatSpecLike.runTest$(FlatSpecLike.scala:1674)
org.scalatest.FlatSpec.runTest(FlatSpec.scala:1685)
org.scalatest.FlatSpecLike.$anonfun$runTests$1(FlatSpecLike.scala:1750)
org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:393)
scala.collection.immutable.List.foreach(List.scala:431)
org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:381)
org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:370)
org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:407)
scala.collection.immutable.List.foreach(List.scala:431)
org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:381)
org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:376)
org.scalatest.SuperEngine.runTestsImpl(Engine.scala:458)
org.scalatest.FlatSpecLike.runTests(FlatSpecLike.scala:1750)
org.scalatest.FlatSpecLike.runTests$(FlatSpecLike.scala:1749)
org.scalatest.FlatSpec.runTests(FlatSpec.scala:1685)
org.scalatest.Suite.run(Suite.scala:1124)
org.scalatest.Suite.run$(Suite.scala:1106)
org.scalatest.FlatSpec.org$scalatest$FlatSpecLike$$super$run(FlatSpec.scala:1685)
org.scalatest.FlatSpecLike.$anonfun$run$1(FlatSpecLike.scala:1795)
org.scalatest.SuperEngine.runImpl(Engine.scala:518)
org.scalatest.FlatSpecLike.run(FlatSpecLike.scala:1795)
org.scalatest.FlatSpecLike.run$(FlatSpecLike.scala:1793)
org.scalatest.FlatSpec.run(FlatSpec.scala:1685)
org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:45)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
Cause:  sun.security.validator.ValidatorException
Message:    PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:456)
sun.security.validator.PKIXValidator.engineValidate(PKIXValidator.java:323)
sun.security.validator.Validator.validate(Validator.java:271)
sun.security.ssl.X509TrustManagerImpl.validate(X509TrustManagerImpl.java:315)
sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:223)
sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:129)
sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:638)
sun.security.ssl.CertificateMessage$T12CertificateConsumer.onCertificate(CertificateMessage.java:473)
sun.security.ssl.CertificateMessage$T12CertificateConsumer.consume(CertificateMessage.java:369)
sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:377)
sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:444)
sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:422)
sun.security.ssl.TransportContext.dispatch(TransportContext.java:182)
sun.security.ssl.SSLTransport.decode(SSLTransport.java:152)
sun.security.ssl.SSLSocketImpl.decode(SSLSocketImpl.java:1392)
sun.security.ssl.SSLSocketImpl.readHandshakeRecord(SSLSocketImpl.java:1300)
sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:435)
sun.net.www.protocol.https.HttpsClient.afterConnect(HttpsClient.java:559)
sun.net.www.protocol.https.AbstractDelegateHttpsURLConnection.connect(AbstractDelegateHttpsURLConnection.java:197)
sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1567)
sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1495)
java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:480)
sun.net.www.protocol.https.HttpsURLConnectionImpl.getResponseCode(HttpsURLConnectionImpl.java:352)
io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:277)
io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:367)
io.confluent.kafka.schemaregistry.client.rest.RestService.getLatestVersion(RestService.java:893)
io.confluent.kafka.schemaregistry.client.rest.RestService.getLatestVersion(RestService.java:884)
io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getLatestSchemaMetadata(CachedSchemaRegistryClient.java:469)
za.co.absa.abris.avro.registry.AbstractConfluentRegistryClient.getLatestSchemaMetadata(AbstractConfluentRegistryClient.scala:38)
za.co.absa.abris.avro.read.confluent.SchemaManager.getSchemaMetadataBySubjectAndVersion(SchemaManager.scala:66)
za.co.absa.abris.avro.read.confluent.SchemaManager.getSchemaBySubjectAndVersion(SchemaManager.scala:55)
za.co.absa.abris.avro.read.confluent.SchemaManager.getSchema(SchemaManager.scala:46)
za.co.absa.abris.config.FromSchemaDownloadingConfigFragment.usingSchemaRegistry(Config.scala:250)
za.co.absa.abris.config.FromSchemaDownloadingConfigFragment.usingSchemaRegistry(Config.scala:245)
com.expedia.ers.security.data.dataloader.internal.utils.DataFrameUtil$.getFromAvroConfig(DataFrameUtil.scala:52)
com.expedia.ers.security.data.dataloader.internal.utils.DataFrameUtil$.applyEGSPDfSchema(DataFrameUtil.scala:30)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSource.loadEGSPStreamDF(EgspKafkaDataSource.scala:64)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSource.loadDataFrame(EgspKafkaDataSource.scala:41)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSourceTest.$anonfun$new$6(EgspKafkaDataSourceTest.scala:123)
com.expedia.ers.security.data.common.utils.SparkContextSetup.withSparkSession(SparkContextSetup.scala:18)
com.expedia.ers.security.data.common.utils.SparkContextSetup.withSparkSession$(SparkContextSetup.scala:12)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSourceTest.withSparkSession(EgspKafkaDataSourceTest.scala:25)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSourceTest.$anonfun$new$5(EgspKafkaDataSourceTest.scala:114)
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
org.scalatest.Transformer.apply(Transformer.scala:22)
org.scalatest.Transformer.apply(Transformer.scala:20)
org.scalatest.FlatSpecLike$$anon$5.apply(FlatSpecLike.scala:1682)
org.scalatest.TestSuite.withFixture(TestSuite.scala:196)
org.scalatest.TestSuite.withFixture$(TestSuite.scala:195)
org.scalatest.FlatSpec.withFixture(FlatSpec.scala:1685)
org.scalatest.FlatSpecLike.invokeWithFixture$1(FlatSpecLike.scala:1680)
org.scalatest.FlatSpecLike.$anonfun$runTest$1(FlatSpecLike.scala:1692)
org.scalatest.SuperEngine.runTestImpl(Engine.scala:286)
org.scalatest.FlatSpecLike.runTest(FlatSpecLike.scala:1692)
org.scalatest.FlatSpecLike.runTest$(FlatSpecLike.scala:1674)
org.scalatest.FlatSpec.runTest(FlatSpec.scala:1685)
org.scalatest.FlatSpecLike.$anonfun$runTests$1(FlatSpecLike.scala:1750)
org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:393)
scala.collection.immutable.List.foreach(List.scala:431)
org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:381)
org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:370)
org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:407)
scala.collection.immutable.List.foreach(List.scala:431)
org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:381)
org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:376)
org.scalatest.SuperEngine.runTestsImpl(Engine.scala:458)
org.scalatest.FlatSpecLike.runTests(FlatSpecLike.scala:1750)
org.scalatest.FlatSpecLike.runTests$(FlatSpecLike.scala:1749)
org.scalatest.FlatSpec.runTests(FlatSpec.scala:1685)
org.scalatest.Suite.run(Suite.scala:1124)
org.scalatest.Suite.run$(Suite.scala:1106)
org.scalatest.FlatSpec.org$scalatest$FlatSpecLike$$super$run(FlatSpec.scala:1685)
org.scalatest.FlatSpecLike.$anonfun$run$1(FlatSpecLike.scala:1795)
org.scalatest.SuperEngine.runImpl(Engine.scala:518)
org.scalatest.FlatSpecLike.run(FlatSpecLike.scala:1795)
org.scalatest.FlatSpecLike.run$(FlatSpecLike.scala:1793)
org.scalatest.FlatSpec.run(FlatSpec.scala:1685)
org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:45)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
Cause:  sun.security.provider.certpath.SunCertPathBuilderException
Message:    PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
sun.security.provider.certpath.SunCertPathBuilder.build(SunCertPathBuilder.java:141)
sun.security.provider.certpath.SunCertPathBuilder.engineBuild(SunCertPathBuilder.java:126)
java.security.cert.CertPathBuilder.build(CertPathBuilder.java:280)
sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:451)
sun.security.validator.PKIXValidator.engineValidate(PKIXValidator.java:323)
sun.security.validator.Validator.validate(Validator.java:271)
sun.security.ssl.X509TrustManagerImpl.validate(X509TrustManagerImpl.java:315)
sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:223)
sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:129)
sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:638)
sun.security.ssl.CertificateMessage$T12CertificateConsumer.onCertificate(CertificateMessage.java:473)
sun.security.ssl.CertificateMessage$T12CertificateConsumer.consume(CertificateMessage.java:369)
sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:377)
sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:444)
sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:422)
sun.security.ssl.TransportContext.dispatch(TransportContext.java:182)
sun.security.ssl.SSLTransport.decode(SSLTransport.java:152)
sun.security.ssl.SSLSocketImpl.decode(SSLSocketImpl.java:1392)
sun.security.ssl.SSLSocketImpl.readHandshakeRecord(SSLSocketImpl.java:1300)
sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:435)
sun.net.www.protocol.https.HttpsClient.afterConnect(HttpsClient.java:559)
sun.net.www.protocol.https.AbstractDelegateHttpsURLConnection.connect(AbstractDelegateHttpsURLConnection.java:197)
sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1567)
sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1495)
java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:480)
sun.net.www.protocol.https.HttpsURLConnectionImpl.getResponseCode(HttpsURLConnectionImpl.java:352)
io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:277)
io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:367)
io.confluent.kafka.schemaregistry.client.rest.RestService.getLatestVersion(RestService.java:893)
io.confluent.kafka.schemaregistry.client.rest.RestService.getLatestVersion(RestService.java:884)
io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getLatestSchemaMetadata(CachedSchemaRegistryClient.java:469)
za.co.absa.abris.avro.registry.AbstractConfluentRegistryClient.getLatestSchemaMetadata(AbstractConfluentRegistryClient.scala:38)
za.co.absa.abris.avro.read.confluent.SchemaManager.getSchemaMetadataBySubjectAndVersion(SchemaManager.scala:66)
za.co.absa.abris.avro.read.confluent.SchemaManager.getSchemaBySubjectAndVersion(SchemaManager.scala:55)
za.co.absa.abris.avro.read.confluent.SchemaManager.getSchema(SchemaManager.scala:46)
za.co.absa.abris.config.FromSchemaDownloadingConfigFragment.usingSchemaRegistry(Config.scala:250)
za.co.absa.abris.config.FromSchemaDownloadingConfigFragment.usingSchemaRegistry(Config.scala:245)
com.expedia.ers.security.data.dataloader.internal.utils.DataFrameUtil$.getFromAvroConfig(DataFrameUtil.scala:52)
com.expedia.ers.security.data.dataloader.internal.utils.DataFrameUtil$.applyEGSPDfSchema(DataFrameUtil.scala:30)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSource.loadEGSPStreamDF(EgspKafkaDataSource.scala:64)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSource.loadDataFrame(EgspKafkaDataSource.scala:41)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSourceTest.$anonfun$new$6(EgspKafkaDataSourceTest.scala:123)
com.expedia.ers.security.data.common.utils.SparkContextSetup.withSparkSession(SparkContextSetup.scala:18)
com.expedia.ers.security.data.common.utils.SparkContextSetup.withSparkSession$(SparkContextSetup.scala:12)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSourceTest.withSparkSession(EgspKafkaDataSourceTest.scala:25)
com.expedia.ers.security.data.dataloader.internal.datasource.egspkafka.EgspKafkaDataSourceTest.$anonfun$new$5(EgspKafkaDataSourceTest.scala:114)
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
org.scalatest.Transformer.apply(Transformer.scala:22)
org.scalatest.Transformer.apply(Transformer.scala:20)
org.scalatest.FlatSpecLike$$anon$5.apply(FlatSpecLike.scala:1682)
org.scalatest.TestSuite.withFixture(TestSuite.scala:196)
org.scalatest.TestSuite.withFixture$(TestSuite.scala:195)
org.scalatest.FlatSpec.withFixture(FlatSpec.scala:1685)
org.scalatest.FlatSpecLike.invokeWithFixture$1(FlatSpecLike.scala:1680)
org.scalatest.FlatSpecLike.$anonfun$runTest$1(FlatSpecLike.scala:1692)
org.scalatest.SuperEngine.runTestImpl(Engine.scala:286)
org.scalatest.FlatSpecLike.runTest(FlatSpecLike.scala:1692)
org.scalatest.FlatSpecLike.runTest$(FlatSpecLike.scala:1674)
org.scalatest.FlatSpec.runTest(FlatSpec.scala:1685)
org.scalatest.FlatSpecLike.$anonfun$runTests$1(FlatSpecLike.scala:1750)
org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:393)
scala.collection.immutable.List.foreach(List.scala:431)
org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:381)
org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:370)
org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:407)
scala.collection.immutable.List.foreach(List.scala:431)
org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:381)
org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:376)
org.scalatest.SuperEngine.runTestsImpl(Engine.scala:458)
org.scalatest.FlatSpecLike.runTests(FlatSpecLike.scala:1750)
org.scalatest.FlatSpecLike.runTests$(FlatSpecLike.scala:1749)
org.scalatest.FlatSpec.runTests(FlatSpec.scala:1685)
org.scalatest.Suite.run(Suite.scala:1124)
org.scalatest.Suite.run$(Suite.scala:1106)
org.scalatest.FlatSpec.org$scalatest$FlatSpecLike$$super$run(FlatSpec.scala:1685)
org.scalatest.FlatSpecLike.$anonfun$run$1(FlatSpecLike.scala:1795)
org.scalatest.SuperEngine.runImpl(Engine.scala:518)
org.scalatest.FlatSpecLike.run(FlatSpecLike.scala:1795)
org.scalatest.FlatSpecLike.run$(FlatSpecLike.scala:1793)
org.scalatest.FlatSpec.run(FlatSpec.scala:1685)
org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:45)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
cerveada commented 2 years ago

This seems to be the same issue: https://github.com/AbsaOSS/ABRiS/issues/179

You are correctly using .withSchemaRegistryConfig(schemaRegistryConfig.toMap), but you will have to check confluent schema registry client to find out what is the right security configuration.

kishoreraj05 commented 2 years ago

@cerveada thanks for your prompt reply. In issue : #233, I see that there issue was fixed by passing truststore and keystore location but I am passing ssl.truststore.certificates and ssl.keystore.certificate.chain. is this fine?

cerveada commented 2 years ago

I don't know. If I were you, I would start by reading the confluent documentation: https://docs.confluent.io/platform/current/schema-registry/security/index.html#clients-to-sr (change the confluent version to the one you use)

If you figure this out, please write back what worked for you. So other people can find it here.

kishoreraj05 commented 2 years ago

Issue resolved. Earlier I was using io.confluent:kafka-schema-registry-client:7.0.1 Once I moved to io.confluent:kafka-schema-registry-client:7.1.1 issue got resolved.