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 2016/11/11 19:42:58 UTC
[jira] [Resolved] (KAFKA-2076) Add an API to new consumer to allow
user get high watermark of partitions.
[ https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jiangjie Qin resolved KAFKA-2076.
---------------------------------
Resolution: Fixed
Fix Version/s: 0.10.1.0
After KIP-79(https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65868090) the consumers are able to get the high watermark of the logs. Closing this ticket.
> 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: Sub-task
> Reporter: Jiangjie Qin
> Assignee: Jiangjie Qin
> Fix For: 0.10.1.0
>
>
> 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)