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

1wnzp6jl  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(626)

我正在用Kafka制作数据并加以利用。在consumer中,我使用以下代码打印消耗的数据:

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吗?我怎样才能告诉消费者把这个处理时间改成另一个时区呢?谢谢

p8ekf7hl

p8ekf7hl1#

那是纪元时间,所以它独立于任何时区。您可以使用任何epoch转换器(在线)将其转换为人类可读的时间https://www.epochconverter.com/)

相关问题