Jiangjie Qin created KAFKA-2076: ----------------------------------- Summary: 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
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)