Hi All,
We started getting the following weird error since today. We are trying to trouble shoot but no luck so far. Anyone know what could cause this please?
Version : Debezium Server 3.2.0.Final
Connector : Oracle
Sink : RabbitMQ
2025-08-28 08:47:13,436 dcmidvmmox001 /opt/openjdk/jdk21.0.8/bin/java[20536] ERROR [io.deb.ser.ConnectorLifecycle] (pool-7-thread-1) Connector completed: success = 'false', message = 'org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: "schema", schema type: STRING', error = 'org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: "schema", schema type: STRING': org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: "schema", schema type: STRING
at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:224)
at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:217)
at org.apache.kafka.connect.data.Struct.put(Struct.java:216)
at org.apache.kafka.connect.data.Struct.put(Struct.java:203)
at io.debezium.connector.oracle.OracleSourceInfoStructMaker.struct(OracleSourceInfoStructMaker.java:51)
at io.debezium.connector.oracle.OracleSourceInfoStructMaker.struct(OracleSourceInfoStructMaker.java:15)
at io.debezium.connector.AbstractSourceInfo.struct(AbstractSourceInfo.java:79)
at io.debezium.pipeline.CommonOffsetContext.getSourceInfo(CommonOffsetContext.java:58)
at io.debezium.connector.common.BaseSourceTask.validateSchemaHistory(BaseSourceTask.java:157)
at io.debezium.connector.oracle.OracleConnectorTask.start(OracleConnectorTask.java:113)
at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:260)
at io.debezium.embedded.async.AsyncEmbeddedEngine.lambda$startSourceTasks$2(AsyncEmbeddedEngine.java:429)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583)