kafka连接转换

oxiaedzo  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(195)

我想将数据从postgresql流式传输到hdfs,但是我所有的表都有多个timestamp列。我曾经尝试过confluent提供的简单JDBCConnect和HDFSsink从postgres读取数据并将其写入hdfs,但我的所有日期列都转换为bigint格式,而不是日期格式。我不知道这个大int是哪种格式的,但它不是unix时间戳格式的。有什么原因要找出它是哪种格式的吗?我还考虑将日期列转换为jdbc connect中的unix时间戳,然后使用timestampconverter将它们转换为sink中的日期。但我不知道如何在我目前的程序中实现它。这里报道了这个问题。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题