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

Invalid Java object for schema type INT64

    XMLWordPrintable

Details

    • Bug
    • Resolution: Duplicate
    • Major
    • None
    • 1.8.0.Alpha1
    • oracle-connector
    • None
    • False
    • False

    Description

      Configuration of DBZ is :

      {
      "name": "oracle",
      "config":

      { "connector.class":"io.debezium.connector.oracle.OracleConnector", "tasks.max":"1", "database.server.name": "oracle", "database.hostname": "xx.x.xx.xx", "database.port": "1521", "database.user": "dbzuser", "database.password": "dbzuser", "database.dbname": "testogg", "database.history.kafka.topic": "oracle-history", "database.history.kafka.bootstrap.servers": "xx.x.xxx.xx:9092", "database.history.skip.unparseable.ddl": "true", "database.history.store.only.captured.tables.ddl": "true", "table.include.list": "SCOTT.T_DBZ_TEST1", "tombstones.on.delete": "false", "decimal.handling.mode": "string", "lob.enabled": "false" }

      }

       
      Table like that:
      CREATE TABLE SCOTT.T_DBZ_TEST1(
      ID NUMBER(10) NOT NULL,
      T_CHAR CHAR(100),
      T_VARCHAR VARCHAR2(100),
      T_NUMBER NUMBER(10),
      T_BLOB BLOB,
      T_DATE DATE DEFAULT SYSDATE,
      T_TIMESTAMP TIMESTAMP,
      T_CLOB CLOB,
      T_DECIMAL NUMBER(10, 2),
      T_NVARCHAR2 NVARCHAR2(10),
      T_FLOAT FLOAT,
      PRIMARY KEY (ID)
      );

      Start the DBZ connector, a few minutes the status occur log:
      org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
      at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)
      at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:180)
      at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:58)
      at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166)
      at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127)
      at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      at java.util.concurrent.FutureTask.run(FutureTask.java:266)
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      at java.lang.Thread.run(Thread.java:748)
      Caused by: org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default value
      at org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:131)
      at io.debezium.relational.TableSchemaBuilder.addField(TableSchemaBuilder.java:380)
      at io.debezium.relational.TableSchemaBuilder.lambda$create$2(TableSchemaBuilder.java:122)
      at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
      at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
      at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
      at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
      at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
      at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
      at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
      at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
      at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:418)
      at io.debezium.relational.TableSchemaBuilder.create(TableSchemaBuilder.java:120)
      at io.debezium.relational.RelationalDatabaseSchema.buildAndRegisterSchema(RelationalDatabaseSchema.java:135)
      at io.debezium.connector.oracle.OracleDatabaseSchema.lambda$applySchemaChange$0(OracleDatabaseSchema.java:80)
      at java.lang.Iterable.forEach(Iterable.java:75)
      at io.debezium.connector.oracle.OracleDatabaseSchema.applySchemaChange(OracleDatabaseSchema.java:79)
      at io.debezium.pipeline.EventDispatcher$SchemaChangeEventReceiver.schemaChangeEvent(EventDispatcher.java:539)
      at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:116)
      at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:305)
      at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.dispatchSchemaChangeEventAndGetTableForNewCapturedTable(AbstractLogMinerEventProcessor.java:525)
      at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.getTableForDataEvent(AbstractLogMinerEventProcessor.java:459)
      at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleDataEvent(AbstractLogMinerEventProcessor.java:394)
      at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:203)
      at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:161)
      at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:116)
      at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:167)

      Caused by: org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type INT64: class java.lang.String for field: \"null\"
      at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:244)
      at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:213)
      at org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:129)

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              jiajingsi jingsi jia (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: