oracdc
oracdc copied to clipboard
"Invalid value 2 for configuration a2.schema.type: String must be one of: kafka, single, debezium." with solutions.a2.cdc.oracle.OraCdcSourceConnector
hello ! here is the bug i've obtained with oracdc with materialized views :
[2024-10-23 13:50:10,755] INFO [ora-source-yield|task-1] Starting oracdc Source Task for EMP (solutions.a2.cdc.oracle.OraCdcSourceTask:59)
[2024-10-23 13:50:10,755] ERROR [ora-source-yield|task-1] WorkerSourceTask{id=ora-source-yield-1} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:212)
org.apache.kafka.connect.errors.ConnectException: Couldn't start oracdc due to coniguration error
at solutions.a2.cdc.oracle.OraCdcSourceTask.start(OraCdcSourceTask.java:64)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.initializeAndStart(AbstractWorkerSourceTask.java:280)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:202)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:77)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.base/java.lang.Thread.run(Unknown Source)
Caused by: org.apache.kafka.common.config.ConfigException: Invalid value 2 for configuration a2.schema.type: String must be one of: kafka, single, debezium
at org.apache.kafka.common.config.ConfigDef$ValidString.ensureValid(ConfigDef.java:1016)
at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:502)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:486)
at org.apache.kafka.common.config.AbstractConfig.
even if i force a2.schema.type in JSON file, i always obtain the same message : Invalid value 2 for configuration a2.schema.type: String must be one of: kafka, single, debezium. thanks in advance best regards