-
Bug
-
Resolution: Unresolved
-
Minor
-
None
-
None
-
False
-
-
False
-
Low
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?
debezium-jdbc , version:3.0.0.Final
What is the connector configuration?
this is my sink connector configuration, i used docker to build the debezium, and this target db in virtual machine:
{
"connector.class": "io.debezium.connector.jdbc.JdbcSinkConnector",
"hibernate.connection.driver_class": "oracle.jdbc.OracleDriver",
"table.name.format": "${source.table}",
"hibernate.database.type": "oracle",
"connection.password": "xtreamuser",
"primary.key.mode": "record_key",
"hibernate.default_catalog": "XTREAMUSER",
"tasks.max": "1",
"batch.size": "1000",
"hibernate.dialect": "org.hibernate.dialect.OracleDialect",
"connection.username": "xtreamuser",
"connection.provider": "com.olm.debezium.DynamicConnectionProvider",
"hibernate.driver.version": "oracle-12c",
"topics": "olm_cdc_test.cdc.mysql_source_type_demo",
"collection.name.format": "${source.table}",
"hibernate.connection.url": "jdbc:oracle:thin:@192.168.238.138:1521:ORCL",
"delete.enabled": "true",
"schema.evolution": "basic",
"name": "test-hasPk-sink",
"connection.url": "jdbc:oracle:thin:@192.168.238.138:1521:ORCL",
"hibernate.schema": "XTREAMUSER",
"insert.mode": "upsert"
}
What is the captured database version and mode of deployment?
(E.g. on-premises, with a specific cloud provider, etc.)
the source database : mysql
the source databse version: 5.7.42-log
What behavior do you expect?
i expect that mysql's 'geometry' data type can be normally got and converted
What behavior do you see?
i see connector's log , the error message is "Failed to resolve column type for schema: STRUCT (io.debezium.data.geometry.Geometry)" in log file.
Do you see the same behaviour using the latest released Debezium version?
(Ideally, also verify with latest Alpha/Beta/CR version)
i don't , i just used 3.0.0.Final version. but i see debezium-jdbc source code that 3.0 version, , the MySqlDatabaseDialect.registerTypes() already registed the type 'GeometryType', i don't understand why tell me that "Failed to resolve column type for schema: STRUCT (io.debezium.data.geometry.Geometry)";
Do you have the connector logs, ideally from start till finish?
(You might be asked later to provide DEBUG/TRACE level log)
this is my sink connector logs:
ERROR [task-thread-test-hasPk-sink-0:JdbcSinkConnectorTask@137] - Failed to process record: Failed to process a sink record
2025-09-24 10:24:08 org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record
2025-09-24 10:24:08 at io.debezium.connector.jdbc.JdbcChangeEventSink.buildRecordSinkDescriptor(JdbcChangeEventSink.java:209)
2025-09-24 10:24:08 at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:93)
2025-09-24 10:24:08 at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:128)
2025-09-24 10:24:08 at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:605)
2025-09-24 10:24:08 at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:344)
2025-09-24 10:24:08 at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:246)
2025-09-24 10:24:08 at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:215)
2025-09-24 10:24:08 at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:225)
2025-09-24 10:24:08 at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:280)
2025-09-24 10:24:08 at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)
2025-09-24 10:24:08 at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
2025-09-24 10:24:08 at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
2025-09-24 10:24:08 at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
2025-09-24 10:24:08 at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
2025-09-24 10:24:08 at java.base/java.lang.Thread.run(Thread.java:1583)
2025-09-24 10:24:08 Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to resolve column type for schema: STRUCT (io.debezium.data.geometry.Geometry)
2025-09-24 10:24:08 at io.debezium.connector.jdbc.dialect.GeneralDatabaseDialect.getSchemaType(GeneralDatabaseDialect.java:485)
2025-09-24 10:24:08 at io.debezium.connector.jdbc.SinkRecordDescriptor$FieldDescriptor.<init>(SinkRecordDescriptor.java:196)
2025-09-24 10:24:08 at io.debezium.connector.jdbc.SinkRecordDescriptor$Builder.applyNonKeyField(SinkRecordDescriptor.java:480)
2025-09-24 10:24:08 at io.debezium.connector.jdbc.SinkRecordDescriptor$Builder.applyNonKeyFields(SinkRecordDescriptor.java:473)
2025-09-24 10:24:08 at io.debezium.connector.jdbc.SinkRecordDescriptor$Builder.readSinkRecordNonKeyData(SinkRecordDescriptor.java:464)
2025-09-24 10:24:08 at io.debezium.connector.jdbc.SinkRecordDescriptor$Builder.build(SinkRecordDescriptor.java:315)
2025-09-24 10:24:08 at io.debezium.connector.jdbc.JdbcChangeEventSink.buildRecordSinkDescriptor(JdbcChangeEventSink.java:206)
2025-09-24 10:24:08 ... 14 more
How to reproduce the issue using our tutorial deployment?
<Your answer>
Feature request or enhancement
For feature requests or enhancements, provide this information, please:
Which use case/requirement will be addressed by the proposed feature?
<Your answer>
Implementation ideas (optional)
<Your answer>