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 <b...@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 <fhussonn...@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 >
