You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Florian Hussonnois <fh...@gmail.com> on 2016/02/10 10:23:50 UTC

How to retrieve the HighWaterMark

Hi all,

I'm looking for a way to retrieve the HighWaterMark using the new API.

Is that possible ?

Thank you in advance

-- 
Florian HUSSONNOIS

Re: How to retrieve the HighWaterMark

Posted by Ben Stopford <be...@confluent.io>.

As an aside - you should also be able to validate this against the replication-offset-checkpoint file for each topic partition, server side.

> On 11 Feb 2016, at 09:02, Ben Stopford <be...@confluent.io> wrote:
> 
> Hi Florian
> 
> I think you should be able to get it by calling consumer.seekToEnd() followed by consumer.position() for each topic partition. 
> 
> B
> 
>> On 10 Feb 2016, at 09:23, Florian Hussonnois <fh...@gmail.com> wrote:
>> 
>> Hi all,
>> 
>> I'm looking for a way to retrieve the HighWaterMark using the new API.
>> 
>> Is that possible ?
>> 
>> Thank you in advance
>> 
>> -- 
>> Florian HUSSONNOIS
>

Re: How to retrieve the HighWaterMark

Posted by Ben Stopford <be...@confluent.io>.

Hi Florian

I think you should be able to get it by calling consumer.seekToEnd() followed by consumer.position() for each topic partition. 

B

> On 10 Feb 2016, at 09:23, Florian Hussonnois <fh...@gmail.com> wrote:
> 
> Hi all,
> 
> I'm looking for a way to retrieve the HighWaterMark using the new API.
> 
> Is that possible ?
> 
> Thank you in advance
> 
> -- 
> Florian HUSSONNOIS