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

Connector fails when using '$' sign in column name.

    XMLWordPrintable

Details

    Description

      Connector fails when using '$' sign in column name with stacktrace:

       

       

      [2020-12-11 13:52:07,270] ERROR WorkerSourceTask{id=TWCMS_Inhouse_TEST-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179)
      org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler
       at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:178)
       at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104)
       at org.apache.kafka.connect.runtime.WorkerSourceTask.convertTransformedRecord(WorkerSourceTask.java:287)
       at org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:316)
       at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:240)
       at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
       at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
       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.avro.SchemaParseException: Illegal character in: UP$OWNERID
       at org.apache.avro.Schema.validateName(Schema.java:1532)
       at org.apache.avro.Schema.access$400(Schema.java:87)
       at org.apache.avro.Schema$Field.<init>(Schema.java:520)
       at org.apache.avro.Schema$Field.<init>(Schema.java:559)
       at io.confluent.connect.avro.AvroData.addAvroRecordField(AvroData.java:1041)
       at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:900)
       at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:732)
       at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:726)
       at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:365)
       at io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:80)
       at org.apache.kafka.connect.storage.Converter.fromConnectData(Converter.java:62)
       at org.apache.kafka.connect.runtime.WorkerSourceTask.lambda$convertTransformedRecord$1(WorkerSourceTask.java:287)
       at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128)
       at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:162)
       ... 11 more
      [2020-12-11 13:52:07,271] ERROR WorkerSourceTask{id=TWCMS_Inhouse_TEST-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:180)
      [2020-12-11 13:52:07,271] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask:192)

      Attachments

        Activity

          People

            ccranfor@redhat.com Chris Cranford
            ant0nk Anton Kondratev (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: