JDBC Sink Connector ConnectException - Table "schema"."table" is missing and auto-creation is disabled for oracle

Kafka Connect
1

I am trying to sink data from kafka topic “kafka2.INVENTORY.PRODUCT” to table “product_target” under different schema having schema name “tinventory” with Oracle DB. This sink I am trying with the DB connection user “jdbcsinkuser”.

Doing this I am getting error as

ERROR [sink-to-target|task-0] WorkerSinkTask{id=sink-to-target-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: Table "tinventory"."PRODUCT_TARGET" is missing and auto-creation is disabled (org.apache.kafka.connect.runtime.WorkerSinkTask:609)
org.apache.kafka.connect.errors.ConnectException: Table "tinventory"."PRODUCT_TARGET" is missing and auto-creation is disabled

{
    "name": "sink-to-target",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
        "tasks.max": "1",
        "topics": "kafka2.INVENTORY.PRODUCT",
        "table.name.format": "PRODUCT_TARGET",
        "connection.url": "jdbc:oracle:thin:@localhost:1521/orclpdb1",
        "connection.user": "jdbcsinkuser",
        "connection.password": "jdbc",
        "transforms": "unwrap,InsertField",
        "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
        "pk.fields": "PRODUCTID",
        "insert.mode":"upsert",
        "delete.enabled":true,
        "delete.retention.ms":100,
        "pk.mode": "record_key",
        "transforms.InsertField.type": "org.apache.kafka.connect.transforms.InsertField$Value",
        "transforms.InsertField.static.field": "SOURCE",
        "transforms.InsertField.static.value": "LEGACY-SYS"
    }
}
2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.