kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jon Yeargers <jon.yearg...@cedexis.com>
Subject lag monitoring
Date Mon, 05 Dec 2016 11:47:46 GMT
Is there a way to get updated consumer position(s) without subscribing to a
topic? I can achieve this by continually closing / reopening a
KafkaConsumer object but this is problematic as it often times out.

Im getting consumer lag from a combination of

(start) .seekToEnd() (and then) .position()


(end) .committed()

but if I wait and call this set of functions again I get the same values.

How do I refresh this connection without interfering with the actual
consumer group position(s)?

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message