Currently the

messageGap

metric maintains the state of the latest timestamp “seen” by the indexing task. So I want to emit a

"maximum" message gap

or

every message gap

, but I see the metrics emit by the interval(I can’t sure how long), so the

max message gap will continue in the interval

and

can't emit every message

. Anyone can give me some help?