datetime - kafka消费者时间戳使用哪个时区以及如何更改它?
问题描述
我正在使用 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吗?以及如何告诉消费者将此处理时间更改为另一个时区?谢谢
解决方案
那是纪元时间,因此它独立于任何时区。您可以使用任何纪元转换器将其转换为人类可读的时间(在此处在线https://www.epochconverter.com/)
推荐阅读
- r - 为什么某些 R 包在新版本中不更改版本号
- html - 为什么我不能将下拉菜单放在按钮下?
- python - 有没有人在 google colab notebook 中成功嵌入了散景服务器?
- java - Azure IoT 中心:“签名证书信息与链元素不匹配”
- d3.js - D3 模块加载产生无法读取未定义的属性“文档”
- django - 如何使用 django 自定义表单保存多对多字段
- html - 有没有人在 HTML Table 中体验过这种边框格式并找到了解决方案?
- php - 使用 oneToMany 关系将动态字段数据数组保存到数据库
- do-while - 当一个条件等于另一个条件但有异常时,如何执行循环?
- reactjs - 导致 React 组件受控/不受控的条件是什么?我有一个改变的例子?