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

【问题标题】：Convert epoch timestamp to date time format using camus properties使用 camus 属性将纪元时间戳转换为日期时间格式
【发布时间】：2018-08-02 07:01:46
【问题描述】：

我的 kafka 消息有多个字段，其中包含长格式的纪元时间戳。我的消息如下所示：

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

当使用 camus 属性文件中的某些属性加载到 hdfs 时，有没有办法将所有这些纪元时间戳转换为日期时间格式。

【问题讨论】：

【解决方案1】：

Camus 已贬值 - 您最好使用 HDFS connector 进行 Kafka Connect。它是开源的，可在standalone 或作为Confluent Platform 的一部分使用。

作为 Kafka Connect 的一部分，您有 Single Message Transforms，您可以使用它来将您的 epoch 转换为更易读的形式 - 请参阅 org.apache.kafka.connect.transforms.TimestampConverter

在blog article here 中查看更多单个消息转换的示例。

【讨论】：