Support another rich temporal types - Githubissues

getindata / kafka-connect-iceberg-sink

Apache License 2.0

76 stars 27 forks source link

Support another rich temporal types #45

Open omri-shaiko opened 1 year ago

omri-shaiko commented 1 year ago

Description

Debezium over MySQL creates an unsupported temporal type: org.apache.kafka.connect.data.Timestamp. I added support to it as a timestamp without a timezone.
Function to convert epoch to timestamp returns the wrong date, Its mainly returns dates from the beginning of 1970 because of the calculation of seconds - Changed it from ofEpochSecond into ofEpochMilli
Added missing documentation about rich-temporal-types flag

Resolves #8

PR Checklist

[x] Tests added - Tests fixed
[x] Changelog updated