From f73d9d734781835efe3533fab1cb2c8346810ce2 Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Wed, 23 Apr 2025 10:50:50 +0300 Subject: [PATCH] fixup group lag metric Signed-off-by: Vasiliy Tolstov --- subscriber.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/subscriber.go b/subscriber.go index 1710dc7..d6b6eac 100644 --- a/subscriber.go +++ b/subscriber.go @@ -119,7 +119,7 @@ func (s *Subscriber) poll(ctx context.Context) { s.Lock() for p, l := range lmap { - s.kopts.Meter.Counter(semconv.BrokerGroupLag, "topic", s.topic, "group", s.opts.Group, "partition", strconv.Itoa(int(p)), "lag", strconv.Itoa(int(l.Lag))) + s.kopts.Meter.Counter(semconv.BrokerGroupLag, "topic", s.topic, "group", s.opts.Group, "partition", strconv.Itoa(int(p))).Set(uint64(l.Lag)) } s.Unlock()