Ltree Support for kafka connect JDBC Sink Connector

[souvikTtn]

Kafka Connect Version : 7.0.1 Jdbc Sink Conector version : 10.2.5

Facing Casting issue when using JDBC sink connector while inserting/sinking varchar data into postgres db with datatype as Ltree. Data type used in kafka table is VARCHAR Data type used in postgres table is Ltree error message ::

ERROR: column "columnName" is of type public.ltree but expression is of type character varying
  Hint: You will need to rewrite or cast the expression.
  Position: 94  Call getNextException to see other errors in the batch.
org.postgresql.util.PSQLException: ERROR: column "columnName" is of type public.ltree but expression is of type character varying.
at io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:122)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:601)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:333)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:234)
        at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:203)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:188)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:243)
        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:829)