我的Kafka消息有多个字段，其中包含长格式的历元时间戳。我的信息如下：
{ "someDate1":1512725505000, "someDate2":1518060461000, "ABC":"XYZ", "PQR":"MNO" }
当使用camus属性文件中的某些属性加载到hdfs时，是否有一种方法可以将所有这些epoch时间戳转换为日期时间格式。
ki1q1bka1#
加缪是贬值-你最好使用Kafka连接hdfs连接器。它是开源的，可以独立使用，也可以作为confluent平台的一部分使用。作为kafka connect的一部分，您有一个消息转换，您可以使用它将您的时代转换为更可读的形式-请参阅 org.apache.kafka.connect.transforms.TimestampConverter 在这篇博客文章中可以看到更多关于单个消息转换的例子。
org.apache.kafka.connect.transforms.TimestampConverter
1条答案
按热度按时间ki1q1bka1#
加缪是贬值-你最好使用Kafka连接hdfs连接器。它是开源的，可以独立使用，也可以作为confluent平台的一部分使用。
作为kafka connect的一部分，您有一个消息转换，您可以使用它将您的时代转换为更可读的形式-请参阅
org.apache.kafka.connect.transforms.TimestampConverter在这篇博客文章中可以看到更多关于单个消息转换的例子。