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)

Reply via email to