我有Vertica调度器,它从Kafka消耗avro数据。Vertica的其中一列是TIMESTAMP,目前,我尝试定义了Avro模式,如下所示:
{
"name":"startDate",
"type": "long",
"logicalType": "timestamp-millis"
},
问题是我的调度程序无法使用数据,而且我在Vertica的调度器表中也找不到任何错误。知道我需要在avro模式中更改什么吗?
发布于 2019-06-04 10:25:09
我认为您的问题可能是Vertica时间戳不是以毫秒为单位的Unix纪元时间(您的Avro模式具有)。
您必须使用BIGINT或字符串类型的列,然后使用一些Vertica日期函数将其转换为可读的时间戳
https://stackoverflow.com/questions/56367245
复制相似问题