2022-06-24 13:39:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:18 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-06-24 13:39:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:18 INFO i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-06-24 13:39:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:18 INFO i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-06-24 13:39:18 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:18 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:39:19 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:19 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:39:19 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:19 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:39:19 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:19 INFO i.a.i.d.k.KafkaDestinationConfig(propertiesByProtocol):81 - Kafka protocol config: {"sasl_mechanism":"PLAIN","sasl_jaas_config":"org.apache.kafka.common.security.scram.ScramLoginModule required username=\"***\" password=\"***\";","security_protocol":"SASL_PLAINTEXT"}
2022-06-24 13:39:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:20 ERROR o.a.k.c.NetworkClient(processDisconnection):765 - [Producer clientId=airbyte-test] Connection to *** failed authentication due to: Client SASL mechanism 'PLAIN' not enabled in the server, enabled mechanisms are [SCRAM-SHA-512, SCRAM-SHA-256]
2022-06-24 13:39:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:20 WARN o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=airbyte-test] Bootstrap broker *** (id: -3 rack: null) disconnected
2022-06-24 13:39:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-06-24 13:39:20 ERROR i.a.i.d.k.KafkaDestination(check):65 - Exception attempting to connect to the Kafka brokers: 
2022-06-24 13:39:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnsupportedSaslMechanismException: Client SASL mechanism 'PLAIN' not enabled in the server, enabled mechanisms are [SCRAM-SHA-512, SCRAM-SHA-256]
2022-06-24 13:39:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 	at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:1316) ~[kafka-clients-2.8.0.jar:?]
2022-06-24 13:39:20 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:39:20 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:39:20 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:39:20 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:39:20 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:39:20 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:39:20 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:39:20 INFO i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - Caused by: org.apache.kafka.common.errors.UnsupportedSaslMechanismException: Client SASL mechanism 'PLAIN' not enabled in the server, enabled mechanisms are [SCRAM-SHA-512, SCRAM-SHA-256]