[
https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486359#comment-14486359
]
Jiangjie Qin commented on KAFKA-2076:
-------------------------------------
Hi [~jkreps],
Actually thought about this again, can we provide a time range to get offsets?
So the interface will be something like:
{code}
PartitionOffsets offsetTimes(TopicPartition tp, long startTime, long endTime)
{code}
If people want to get the HW, they can simply specify both of start and end
time to be Long.Max_Value. What do you think?
> Add an API to new consumer to allow user get high watermark of partitions.
> --------------------------------------------------------------------------
>
> Key: KAFKA-2076
> URL: https://issues.apache.org/jira/browse/KAFKA-2076
> Project: Kafka
> Issue Type: Improvement
> Reporter: Jiangjie Qin
> Assignee: Jiangjie Qin
>
> We have a use case that user wants to know how far it is behind a particular
> partition on startup. Currently in each fetch response, we have high
> watermark for each partition, we only keep a global max-lag metric. It would
> be better that we keep a record of high watermark per partition and update it
> on each fetch response. We can add a new API to let user query the high
> watermark.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
