search

databricks / iceberg-kafka-connect

Apache License 2.0
219 stars 49 forks source link

Cannot save timestamp starting with underscore #175

Open mattyrot opened 11 months ago

mattyrot commented 11 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 10 months ago

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