使用camus属性将epoch时间戳转换为日期时间格式

i34xakig  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(643)

我的Kafka消息有多个字段,其中包含长格式的历元时间戳。我的信息如下:

{
    "someDate1":1512725505000,
    "someDate2":1518060461000,
    "ABC":"XYZ",
    "PQR":"MNO"
}

当使用camus属性文件中的某些属性加载到hdfs时,是否有一种方法可以将所有这些epoch时间戳转换为日期时间格式。

ki1q1bka

ki1q1bka1#

加缪是贬值-你最好使用Kafka连接hdfs连接器。它是开源的,可以独立使用,也可以作为confluent平台的一部分使用。
作为kafka connect的一部分,您有一个消息转换,您可以使用它将您的时代转换为更可读的形式-请参阅 org.apache.kafka.connect.transforms.TimestampConverter 在这篇博客文章中可以看到更多关于单个消息转换的例子。

相关问题