kafka does not delete message when message is consumed, it will purge message when this message is expired. I guess this timeStamp is for checking whether message is expired.
1095193...@qq.com From: Jake Yoon Date: 2018-01-19 11:46 To: users Subject: What's the use of timestamp in ProducerRecord? Hi, I am very new to Kafka. And I have a very basic question. Kafka doc says, *ProducerRecord <https://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html#ProducerRecord(java.lang.String,%20java.lang.Integer,%20java.lang.Long,%20K,%20V)>* (String <http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true> topic, Integer <http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true> partition, Long <http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true> timestamp, K <https://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html> key, V <https://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html> value) and I know the default timestamp is the current time. But I am not sure what's the use of it. - Is it just to log when the record is added? - How Kafka use it for? - Are there any other uses of it? - Can "Consumer" retrieves the timestamp of the "ProducerRecord"? Thanks,
