JDBC Sink: (STRUCT) type doesn't have a mapping to the SQL database column type

Kafka Connect
1

Hello everyone!

I’m conducting a test with Kafka Connect on a table in SQL Server that will be transferred to an Oracle database. The ingestion from SQL Server to Kafka occurred without errors, but the transfer to Oracle is returning the following error:

java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.apache.kafka.connect.errors.ConnectException: azsqldbbnf.databaseTest.dbo.Table.Value (STRUCT) type doesn't have a mapping to the SQL database column type

Here are the Sink configurations:

"connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
"connection.url": "jdbc:oracle:thin:@10.1.10.33:1521:test",
"connection.user": "INTEGRATION",
"connection.password": "*********",
"topics": "azsqldbbnf.databaseTest.dbo.Table",
"insert.mode": "upsert",
"pk.mode": "record_key",
"pk.fields": "Id",
"auto.create": "true",
"auto.evolve": "true",
"db.timezone": "UTC",
"table.name.format": "${topic}",
"key.converter.schemas.enable": "true",
"key.converter": "io.confluent.connect.avro.AvroConverter",
"key.converter.schema.registry.url": "http://10.1.10.21:8081",
"value.converter.schema.registry.url": "http://10.1.10.21:8081",
"value.converter.schemas.enable": "true",
"value.converter": "io.confluent.connect.avro.AvroConverter",
"transforms": "flatten,dropPrefix",
"transforms.flatten.type": "org.apache.kafka.connect.transforms.Flatten$Value",
"transforms.dropPrefix.type": "org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex": "dbo.*",
"transforms.dropPrefix.replacement": "$1"
2

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