[
https://issues.apache.org/jira/browse/KAFKA-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15068715#comment-15068715
]
Jiangjie Qin commented on KAFKA-3025:
-------------------------------------
[~apovzner] Thanks for creating the tickets. I did not create ticket for KIP-32
because it will be implemented together with KIP-31 to avoid two binary
protocol changes. I will convert those two tickets to sub-tasks of KAFKA-2511
and reassign them to me. I will implement KIP-31 and KIIP-32 together myself
after the community reaches agreement on KIP-32.
> 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: Improvement
> Reporter: Anna Povzner
> Assignee: Anna Povzner
>
> The decision about this JIRA assignment is still under discussion with
> [~becket_qin]. Not going to implement without his agreement.
> This JIRA is for changes for KIP-32 excluding broker checking and acting on
> timestamp field in a message.
> This JIRA includes:
> 1. 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)
