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

Exception occurred in the change event producer

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Duplicate
    • Icon: Major Major
    • None
    • None
    • oracle-connector
    • None
    • False
    • False

      Debezium has got an exception like this - 

      trace: "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:160)
      	at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:55)
      	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:165)
      	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: io.debezium.connector.oracle.logminer.parser.DmlParserException: DML statement couldn't be parsed. Please open a Jira issue with the statement 'insert into "IDENTITYDB"."CHANGE_NUMBERS"("COL 1","COL 2","COL 3","COL 4","COL 5","COL 6","COL 7","COL 8") values (HEXTORAW('c502551e432d'),HEXTORAW('696462726f6b65722d616d2d3030312d627473'),HEXTORAW('78790a13181b1012f44b80'),HEXTORAW('4f41757468436c69656e74'),NULL,HEXTORAW('80'),HEXTORAW('4954434c49454e545f31353062383361382d376636642d343031652d623064352d6264336564343762306136395f646e6d3a747275655f6973643a305f6d64653a747275655f6d73743a3130'),HEXTORAW('78790a16181b1012f44b80'));'.
      	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.parseDmlStatement(AbstractLogMinerEventProcessor.java:560)
      	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleDataEvent(AbstractLogMinerEventProcessor.java:401)
      	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:189)
      	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:150)
      	at io.debezium.connector.oracle.logminer.processor.memory.MemoryLogMinerEventProcessor.process(MemoryLogMinerEventProcessor.java:116)
      	at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:147)
      	... 8 more
      Caused by: io.debezium.connector.oracle.logminer.parser.DmlParserException: Failed to parse insert DML: 'insert into "IDENTITYDB"."CHANGE_NUMBERS"("COL 1","COL 2","COL 3","COL 4","COL 5","COL 6","COL 7","COL 8") values (HEXTORAW('c502551e432d'),HEXTORAW('696462726f6b65722d616d2d3030312d627473'),HEXTORAW('78790a13181b1012f44b80'),HEXTORAW('4f41757468436c69656e74'),NULL,HEXTORAW('80'),HEXTORAW('4954434c49454e545f31353062383361382d376636642d343031652d623064352d6264336564343762306136395f646e6d3a747275655f6973643a305f6d64653a747275655f6d73743a3130'),HEXTORAW('78790a16181b1012f44b80'));'
      	at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseInsert(LogMinerDmlParser.java:109)
      	at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parse(LogMinerDmlParser.java:73)
      	at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.parseDmlStatement(AbstractLogMinerEventProcessor.java:554)
      	... 13 more
      Caused by: io.debezium.DebeziumException: No column 'COL 1' found in table 'IDBTSAMHA.WEBEX.COM.IDENTITYDB.CHANGE_NUMBERS'
      	at io.debezium.connector.oracle.logminer.LogMinerHelper.getColumnIndexByName(LogMinerHelper.java:232)
      	at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseColumnValuesClause(LogMinerDmlParser.java:301)
      	at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parseInsert(LogMinerDmlParser.java:104)
      	... 15 more
      
      

      Please help to check.

              ccranfor@redhat.com Chris Cranford
              zouxinyu0328 Ethan Zou (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: