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 wrote:
>
> Hi Florian
>
> I think you should be able to get it by calling consumer.seekToEnd() followed
> by co
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 wrote:
>
> Hi all,
>
> I'm looking for a way to retrieve the HighWaterMark using the new API.
>
> Is th
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
