You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2015/12/23 08:50:46 UTC
[jira] [Updated] (KAFKA-3025) KIP-31&KIP-32 (part 1): Add timestamp
field to message, configs, and Producer/ConsumerRecord
[ https://issues.apache.org/jira/browse/KAFKA-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jiangjie Qin updated KAFKA-3025:
--------------------------------
Summary: KIP-31&KIP-32 (part 1): Add timestamp field to message, configs, and Producer/ConsumerRecord (was: KIP-32 (part 1): Add timestamp field to message, configs, and Producer/ConsumerRecord)
> KIP-31&KIP-32 (part 1): Add timestamp field to message, configs, and Producer/ConsumerRecord
> --------------------------------------------------------------------------------------------
>
> Key: KAFKA-3025
> URL: https://issues.apache.org/jira/browse/KAFKA-3025
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Anna Povzner
> Assignee: Jiangjie Qin
>
> This JIRA is for changes for KIP-32 excluding broker checking and acting on timestamp field in a message.
> This JIRA includes:
> 1. Bump up MessageAndOffset version to version 1 to:
> a. Change absolute offset to relative offset.
> b. Add time field to the message
> Timestamp => int64
> Timestamp is the number of milliseconds since Unix Epoch
> 2. Add time field to both ProducerRecord and Consumer Record
> If a user specifies the timestamp in a ProducerRecord, the ProducerRecord is sent with this timestamp.
> If a user does not specify the timestamp in a ProducerRecord, the producer stamps the ProducerRecord with current time.
> ConsumerRecord will have the timestamp of the message that were stored on broker.
> 3. Add two new configurations to the broker. Configuration is per topic.
> * message.timestamp.type: type of a timestamp. Possible values: CreateTime, LogAppendTime. Default: CreateTime
> * max.message.time.difference.ms: threshold for the acceptable time difference between Timestamp in the message and local time on the broker. Default: Long.MaxValue
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)