JDBC Sink Timestamp Transformation Error

Kafka Connect
1

Hi Team,
I are trying to replicate data between two oracle DB(19c). At source we have Debezium connector and at sink JDBC sink by confluent. I am getting error while replicating timestamp.
Kindly refer below error and jdbc sink config for timestamp transformation

Error: Error:- ERROR WorkerSinkTask{id=jdbc-sink-01-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: Invalid year value (org.apache.kafka.connect.runtime.WorkerSinkTask:607) java.lang.IllegalArgumentException: Invalid year value.

Config: Tried with both below mentioned properties.
Source value :19-JUL-21 09.25.16.000000000 PM
1] transforms.VLD_DATE_CONV.type=org.apache.kafka.connect.transforms.TimestampConverter$Value
transforms.VLD_DATE_CONV.target.type=string
transforms.VLD_DATE_CONV.field=VLD_DATE
transforms.VLD_DATE_CONV.format=dd/MM/yyyy

2]
transforms=VLD_DATE_CONV
transforms.VLD_DATE_CONV.type=org.apache.kafka.connect.transforms.TimestampConverter$Value
transforms.VLD_DATE_CONV.target.type=Timestamp
transforms.VLD_DATE_CONV.field=VLD_DATE
transforms.VLD_DATE_CONV.format=yyyy-MM-dd HH:mm:ss

2

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