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
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
Post a Comment