Kafka消息時間戳(kafka message timestamp)

最近碰到了消息時間戳的問題,因而花了一些功夫研究了一下,特此記錄一下。   Kafka消息的時間戳 在消息中增長了一個時間戳字段和時間戳類型。目前支持的時間戳類型有兩種:  CreateTime 和 LogAppendTime 前者表示producer建立這條消息的時間;後者表示broker接收到這條消息的時間(嚴格來講,是leader broker將這條消息寫入到log的時間)   爲何要加入時
相關文章
相關標籤/搜索