Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-9499

Failed to resolve column type for schema: STRUCT (io.debezium.data.geometry.Geometry)

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Unresolved
    • Icon: Minor Minor
    • under-triaging
    • None
    • jdbc-connector
    • None
    • False
    • Hide

      None

      Show
      None
    • 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>

              Unassigned Unassigned
              jjdyr23@163.com shuren zhou
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated: