2022-06-24 13:51:48 INFO i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/fc9e26ee-c768-4836-88a5-42b45860abb9/0/logs.log 2022-06-24 13:51:48 INFO i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.17-alpha 2022-06-24 13:51:48 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-kafka:0.1.8 exists... 2022-06-24 13:51:48 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-kafka:0.1.8 was found locally. 2022-06-24 13:51:48 INFO i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: fc9e26ee-c768-4836-88a5-42b45860abb9 2022-06-24 13:51:48 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/fc9e26ee-c768-4836-88a5-42b45860abb9/0 --log-driver none --name destination-kafka-check-fc9e26ee-c768-4836-88a5-42b45860abb9-0-oaink --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-kafka:0.1.8 -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.39.17-alpha -e WORKER_JOB_ID=fc9e26ee-c768-4836-88a5-42b45860abb9 airbyte/destination-kafka:0.1.8 check --config source_config.json 2022-06-24 13:51:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:49 INFO i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination 2022-06-24 13:51:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:49 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json} 2022-06-24 13:51:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:49 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination 2022-06-24 13:51:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:49 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK 2022-06-24 13:51:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:49 INFO i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'} 2022-06-24 13:51:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:49 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-24 13:51:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:49 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword 2022-06-24 13:51:49 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:49 INFO i.a.i.d.k.KafkaDestinationConfig(propertiesByProtocol):81 - Kafka protocol config: {"sasl_mechanism":"SCRAM-SHA-256","sasl_jaas_config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"***\" password=\"***\";","security_protocol":"SASL_SSL"} 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:50 ERROR o.a.k.c.NetworkClient(processDisconnection):765 - [Producer clientId=airbyte-test] Connection to *** failed authentication due to: SSL handshake failed 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:50 WARN o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=airbyte-test] Bootstrap broker *** (id: -1 rack: null) disconnected 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:51:50 ERROR i.a.i.d.k.KafkaDestination(check):65 - Exception attempting to connect to the Kafka brokers: 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.(KafkaProducer.java:1316) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:985) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:773) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.kafka.KafkaDestination.check(KafkaDestination.java:57) [io.airbyte.airbyte-integrations.connectors-destination-kafka-0.38.4-alpha.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:140) [io.airbyte.airbyte-integrations.bases-base-java-0.38.4-alpha.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:107) [io.airbyte.airbyte-integrations.bases-base-java-0.38.4-alpha.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85) [io.airbyte.airbyte-integrations.connectors-destination-kafka-0.38.4-alpha.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - Caused by: org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - Caused by: javax.net.ssl.SSLHandshakeException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.Alert.createSSLException(Alert.java:131) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.TransportContext.fatal(TransportContext.java:370) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.TransportContext.fatal(TransportContext.java:313) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.TransportContext.fatal(TransportContext.java:308) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:654) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.CertificateMessage$T12CertificateConsumer.onCertificate(CertificateMessage.java:473) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.CertificateMessage$T12CertificateConsumer.consume(CertificateMessage.java:369) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:396) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:480) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1277) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1264) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.security.AccessController.doPrivileged(AccessController.java:712) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1209) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:430) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:514) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:368) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:291) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.Selector.poll(Selector.java:481) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:327) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:242) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - Caused by: sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:439) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.validator.PKIXValidator.engineValidate(PKIXValidator.java:306) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.validator.Validator.validate(Validator.java:264) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:285) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:144) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:632) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.CertificateMessage$T12CertificateConsumer.onCertificate(CertificateMessage.java:473) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.CertificateMessage$T12CertificateConsumer.consume(CertificateMessage.java:369) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:396) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:480) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1277) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1264) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.security.AccessController.doPrivileged(AccessController.java:712) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1209) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:430) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:514) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:368) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:291) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.Selector.poll(Selector.java:481) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:327) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:242) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - Caused by: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.provider.certpath.SunCertPathBuilder.build(SunCertPathBuilder.java:141) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.provider.certpath.SunCertPathBuilder.engineBuild(SunCertPathBuilder.java:126) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.security.cert.CertPathBuilder.build(CertPathBuilder.java:297) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:434) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.validator.PKIXValidator.engineValidate(PKIXValidator.java:306) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.validator.Validator.validate(Validator.java:264) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:285) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:144) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.CertificateMessage$T12CertificateConsumer.checkServerCerts(CertificateMessage.java:632) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.CertificateMessage$T12CertificateConsumer.onCertificate(CertificateMessage.java:473) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.CertificateMessage$T12CertificateConsumer.consume(CertificateMessage.java:369) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:396) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:480) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1277) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1264) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.security.AccessController.doPrivileged(AccessController.java:712) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1209) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:430) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:514) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:368) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:291) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.common.network.Selector.poll(Selector.java:481) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:561) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:327) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:242) ~[kafka-clients-2.8.0.jar:?] 2022-06-24 13:51:50 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - at java.lang.Thread.run(Thread.java:833) ~[?:?] 2022-06-24 13:51:50 INFO i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...