kafka消费者时间戳使用哪个时区以及如何更改它？答案

【问题标题】：Which timezone is kafka consumer timestamp using and how to change it?kafka消费者时间戳使用哪个时区以及如何更改它？
【发布时间】：2020-10-24 02:52:47
【问题描述】：

我正在使用 Kafka 生成数据并使用它。在消费者中，我使用以下代码打印消费数据：

consumer = connect_kafka_consumer()
for message in consumer:
    print (message)

这是一行的输出：

ConsumerRecord(topic='states', partition=0, offset=7214, timestamp=1603507387101, timestamp_type=0, key=None, value={'sequence': 1354, 'State': 'WA'}, headers=[], checksum=4012375034, serialized_key_size=-1, serialized_value_size=250, serialized_header_size=-1)

我的问题是关于timestamp，我可以使用message.timestamp 获得。那是哪个时区？默认时区是UTC吗？以及如何告诉消费者将此处理时间更改为另一个时区？谢谢

【问题讨论】：

标签： datetime apache-kafka kafka-consumer-api apache-kafka-streams

【解决方案1】：

这是纪元时间，因此它独立于任何时区。您可以使用任何纪元转换器将其转换为人类可读的时间（在线此处https://www.epochconverter.com/）

【讨论】：