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 <[email protected]> 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 <[email protected]> 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 >
