Skip to main content

Mechanism similar to __consumer_offsets but for consumer.endOffsets

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

Comments