Pulsar IO JDBC Postgres Sink with datetimes #23109
Unanswered
wybrenoppedijk
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I am trying to sink messages from a topic to a PostgreSQL database. The messages have the following schema:
The messages should end up in a table that looks like this:
Problem
The default Pulsar PostgreSQL sink deserializes the
timestamp
field to aBigInt
, which results in an error when PostgreSQL expects aTIMESTAMP
type.Question
Can the
timestamp
field be mapped from the message schema to theTIMESTAMP
type in PostgreSQL to avoid this deserialization issue? Or is the only way to use aBigInt
type fortimestamp
in the PostgreSQL table?Beta Was this translation helpful? Give feedback.
All reactions