diff --git a/broadcaster/backlog/backlog.go b/broadcaster/backlog/backlog.go index 448bb79b13..851561f482 100644 --- a/broadcaster/backlog/backlog.go +++ b/broadcaster/backlog/backlog.go @@ -69,6 +69,7 @@ func (b *backlog) Append(bm *m.BroadcastMessage) error { segment = newBacklogSegment() b.head.Store(segment) b.tail.Store(segment) + confirmedSequenceNumberGauge.Update(int64(msg.SequenceNumber)) } prevMsgIdx := segment.End()