-
Bug
-
Resolution: Unresolved
-
Minor
-
2.3.2.Final
-
None
-
False
-
None
-
False
-
Moderate
In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.
Bug report
For bug reports, provide this information, please:
What Debezium connector do you use and what version?
MySQL 2.3.2-Final
What is the connector configuration?
#name=engine
connector.class=io.debezium.connector.mysql.MySqlConnector
#offset.storage=org.apache.kafka.connect.storage.FileOffsetBackingStore
#offset.storage.file.filename=offsets7.dat
#offset.flush.interval.ms=60000
database.hostname=dre-cluster.fyre.ibm.com
database.port=3306
database.user=dbz
database.password=<PW>
database.server.id=123456
table.include.list=mqsi.Lending
schema.history.internal=io.debezium.storage.file.history.FileSchemaHistory
schema.history.internal.file.filename=mysql-schema-history.dat
#database.server.id=85802
#database.server.name=my-app-connector7
#database.history=io.debezium.relational.history.FileDatabaseHistory
#database.history.file.filename=deleteme-dbhistory7.dat
#debezium.source.offset.storage.file.filename=offset.dat
and
Configuration results = Configuration.load(readFile(filename))
.withSystemProperties(Function.identity()).edit()
.with(EmbeddedEngine.ENGINE_NAME, "DebeziumWriter")
.with(EmbeddedEngine.OFFSET_STORAGE, FileOffsetBackingStore.class)
.with("name", "DebeziumWriter")
.with("topic.prefix", "dbserver1")
As you can see from the comments, I've tried a few things...!
What is the captured database version and mode of deployment?
MySQL 8.1.0 in own kubernetes cluster
What behaviour do you expect?
Successful connection
What behaviour do you see?
[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.<init>(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)
Do you see the same behaviour using the latest relesead Debezium version?
I think this is the latest!
Do you have the connector logs, ideally from start till finish?
(You might be asked later to provide DEBUG/TRACE level log)
Yes
How to reproduce the issue using our tutorial deployment?
Dunno, I can provide the source code for the Java connector though. I used your cache-invalidation example for partial inspiration. This works perfectly for PostgreSQL, but I can't get it to work for MySQL