Hey,

Is there any way to continuously get end offsets for all partitions from
the topic or across the whole cluster as with consumer offsets? Periodic
polling consumer.endOffsets
<https://github.com/apache/kafka/blob/dffc7f8c30824cb6bf38c05838a466488cbb1f81/clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java#L239>
is one option, but maybe it can be done in a different way.

-- 
BR,
Michał Łowicki

Reply via email to