Skip to content

Instantly share code, notes, and snippets.

@miller45

miller45/kafka-connect-unixtoiso8601

Created May 31, 2023 17:23
Show Gist options
  • Save miller45/5b39949119cb35cef566307f7ba42c38 to your computer and use it in GitHub Desktop.
Save miller45/5b39949119cb35cef566307f7ba42c38 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafka-connect-unixtoiso8601
#inserting unix timestamps ms sql datetime fields in jdbc-sink (kafka-connect) leads SQLException Arithmetic Overflow
#converting it to a ISO8601 timestamp works. here is a transform example for kafka-connect-json
"transforms": "dateToIso",
"transforms.dateToIso.type": "org.apache.kafka.connect.transforms.TimestampConverter$Value",
"transforms.dateToIso.format": "yyyy-MM-dd'T'HH:mm:ss'Z'",
"transforms.dateToIso.target.type": "string",
"transforms.dateToIso.field": "CreateDate",
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment