Hello Debezium [main] INFO DebeziumWriter - Reading config from mysql.properties Connecting to dre-cluster.fyre.ibm.com [main] INFO org.apache.kafka.connect.json.JsonConverterConfig - JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false [main] INFO org.apache.kafka.connect.json.JsonConverterConfig - JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false [main] INFO io.debezium.embedded.EmbeddedEngine$EmbeddedConfig - EmbeddedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = All header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 60000 offset.flush.timeout.ms = 5000 offset.storage.file.filename = mysql-offset.dat offset.storage.partitions = null offset.storage.replication.factor = null offset.storage.topic = plugin.path = null response.http.headers.config = rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter [main] WARN org.apache.kafka.connect.runtime.WorkerConfig - Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results. [main] INFO io.debezium.converters.CloudEventsConverterConfig - CloudEventsConverterConfig values: converter.type = value data.serializer.type = json schema.name.adjustment.mode = avro serializer.type = json [main] INFO org.apache.kafka.connect.json.JsonConverterConfig - JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false [main] INFO org.apache.kafka.connect.json.JsonConverterConfig - JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true [main] INFO io.debezium.converters.CloudEventsConverterConfig - CloudEventsConverterConfig values: converter.type = value data.serializer.type = json schema.name.adjustment.mode = avro serializer.type = json [main] INFO org.apache.kafka.connect.json.JsonConverterConfig - JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false [main] INFO org.apache.kafka.connect.json.JsonConverterConfig - JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true [pool-1-thread-1] INFO io.debezium.connector.mysql.MySqlConnector - Successfully tested connection for jdbc:mysql://dre-cluster.fyre.ibm.com:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=30000 with user 'dbz' [pool-2-thread-1] INFO io.debezium.jdbc.JdbcConnection - Connection gracefully closed [pool-1-thread-1] ERROR io.debezium.embedded.EmbeddedEngine - null Exception in thread "pool-1-thread-1" org.apache.kafka.common.config.ConfigException: Invalid value io.debezium.storage.kafka.history.KafkaSchemaHistory for configuration schema.history.internal: Class io.debezium.storage.kafka.history.KafkaSchemaHistory could not be found. at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:744) at org.apache.kafka.common.config.ConfigDef$ConfigKey.(ConfigDef.java:1172) at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:152) at io.debezium.config.Field.group(Field.java:453) at io.debezium.config.ConfigDefinition.addToConfigDef(ConfigDefinition.java:104) at io.debezium.config.ConfigDefinition.configDef(ConfigDefinition.java:71) at io.debezium.connector.mysql.MySqlConnectorConfig.configDef(MySqlConnectorConfig.java:922) at io.debezium.connector.mysql.MySqlConnector.config(MySqlConnector.java:76) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:717) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:229) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829)