understanding how Burrow does calculations for Kafka lags -
i'm trying understand how burrow lines time end offset of log polled @ commit_time
in __consumer_offsets
topic.
let polled log end offset topica partition 2 @ 4/6/17 7:00:08.120
, got value of 659256972
now lets offset topic in partition in __consumer_offsets
659257652
commit time of 4/6/17 7:00:08.922
....so lag 659256972 - 659257652 = -680
during time bucket (1s) 4/6/17 7:00:08
...correct?
this happening because logoffset polled earlier when consumer offset committed __consumer_offset
time bucket of 4/6/17 7:00:08
.
how burrow handle this?
i guess broader...how tool claims calculate lag via brokers handle this?
Comments
Post a Comment