Hi
I have a Oracle JDBC source connector running where the table column name(TAX_NAME#1) contains a special character(#). Due to this special character in the column name, the task could not get started with the following error:
"org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:206)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:132)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.convertTransformedRecord(WorkerSourceTask.java:314)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:340)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:264)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:234)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat java.base/java.lang.Thread.run(Thread.java:834)\nCaused by: org.apache.avro.SchemaParseException: Illegal character in: TAX_NAME#1\n\tat org.apache.avro.Schema.validateName(Schema.java:1530)\n\tat org.apache.avro.Schema.access$400(Schema.java:87)\n\tat org.apache.avro.Schema$Field.<init>(Schema.java:518)\n\tat org.apache.avro.Schema$Field.<init>(Schema.java:557)\n\tat io.confluent.connect.avro.AvroData.addAvroRecordField(AvroData.java:1054)\n\tat io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:887)\n\tat io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:710)\n\tat io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:704)\n\tat io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:85)\n\tat org.apache.kafka.connect.storage.Converter.fromConnectData(Converter.java:63)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.lambda$convertTransformedRecord$2(WorkerSourceTask.java:314)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:156)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:190)\n\t... 11 more\n"
It looks like avro schema parser unable to extract the column name due to this special character in the table column name.
Any suggestion to extract the column name will be highly appreciated.
Thanks