一个专注于大数据技术架构与应用分享的技术博客

Kafka消息时间戳及压缩消息对时间戳的处理

Kafka消息中的时间戳表示消息产生的时间,可分为消息发送时间(Producer Time)和消息接收时间(Broker Time)。Producer Time表示消息从客户端发出的时间,带有Producer Time的消息会被存储在topic和partition指定的位置,接下来消费者读取数据时,可以通过消息的Offset找到对应的消息,并获取Producer Time。Broker Time则是指Broker在接收到消息时为消息赋予的时间戳,它是指消息到达Broker的时间,这个时间戳是由Broker生成的。

在Kafka中,消息的时间戳可以用来进行消息的排序和数据清理。在进行消息排序时,Kafka默认会根据消息的时间戳进行排序,以便

赞(1)
版权声明:本文采用知识共享 署名4.0国际许可协议 [BY-NC-SA] 进行授权
文章名称:《Kafka消息时间戳及压缩消息对时间戳的处理》
文章链接:https://macsishu.com/kafkmessage-timestamp-and-compression-processing-of
本站资源仅供个人学习交流,请于下载后24小时内删除,不允许用于商业用途,否则法律问题自行承担。