tabular-io / iceberg-kafka-connect

Apache License 2.0
171 stars 31 forks source link

Cannot save timestamp starting with underscore #175

Open mattyrot opened 6 months ago

mattyrot commented 6 months ago

Hi, I'm trying to set my timestamp column with a name that starts with underscore, we used: "transforms.insertTime.timestamp.field": "_ts" but when trying to send data to the producer but we get an error of DataException: An error occurred converting record, when we are trying to use without an underscore everything works great, Then we add a rename property to the field "transforms.rename.renames":"ts:_ts" and it doesn't save the data with timestamp anymore. Thanks!

bryanck commented 5 months ago

It seems to me as if the transform isn't being applied. Can you post your connector config?