From 1f4cf11afe3b60483c2c1e93fbc43f4a98042571 Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Sat, 13 Apr 2024 02:40:45 +0300 Subject: [PATCH] fix group lag exporter Signed-off-by: Vasiliy Tolstov --- go.mod | 2 +- go.sum | 4 ++-- subscriber.go | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/go.mod b/go.mod index efc6be2..bdb7c92 100644 --- a/go.mod +++ b/go.mod @@ -10,7 +10,7 @@ require ( github.com/twmb/franz-go/pkg/kadm v1.11.0 github.com/twmb/franz-go/pkg/kmsg v1.7.0 go.opentelemetry.io/otel v1.25.0 - go.unistack.org/micro/v3 v3.10.58 + go.unistack.org/micro/v3 v3.10.59 ) require ( diff --git a/go.sum b/go.sum index 9ca47d8..b484fb5 100644 --- a/go.sum +++ b/go.sum @@ -20,8 +20,8 @@ github.com/twmb/franz-go/pkg/kmsg v1.7.0 h1:a457IbvezYfA5UkiBvyV3zj0Is3y1i8EJgqj github.com/twmb/franz-go/pkg/kmsg v1.7.0/go.mod h1:se9Mjdt0Nwzc9lnjJ0HyDtLyBnaBDAd7pCje47OhSyw= go.opentelemetry.io/otel v1.25.0 h1:gldB5FfhRl7OJQbUHt/8s0a7cE8fbsPAtdpRaApKy4k= go.opentelemetry.io/otel v1.25.0/go.mod h1:Wa2ds5NOXEMkCmUou1WA7ZBfLTHWIsp034OVD7AO+Vg= -go.unistack.org/micro/v3 v3.10.58 h1:2lIQUfb3XdVstcKz7LWm7vVs/HGTzDfG9Q902FcU3xM= -go.unistack.org/micro/v3 v3.10.58/go.mod h1:erMgt3Bl7vQQ0e9UpQyR5NlLiZ9pKeEJ9+1tfYFaqUg= +go.unistack.org/micro/v3 v3.10.59 h1:eneYXJLgyu5MZpSvyI0K17CeXvgOoUCN5dWZaPV5lI4= +go.unistack.org/micro/v3 v3.10.59/go.mod h1:erMgt3Bl7vQQ0e9UpQyR5NlLiZ9pKeEJ9+1tfYFaqUg= golang.org/x/crypto v0.22.0 h1:g1v0xeRhjcugydODzvb3mEM9SQ0HGp9s/nh3COQ/C30= golang.org/x/crypto v0.22.0/go.mod h1:vr6Su+7cTlO45qkww3VDJlzDn0ctJvRgYbC2NvXHt+M= golang.org/x/net v0.21.0 h1:AQyQV4dYCvJ7vGmJyKki9+PBdyvhkSd8EIx/qb0AYv4= diff --git a/subscriber.go b/subscriber.go index 96871ad..2026834 100644 --- a/subscriber.go +++ b/subscriber.go @@ -91,7 +91,7 @@ func (s *subscriber) poll(ctx context.Context) { ticker.Stop() return case <-ticker.C: - dgls, err := ac.Lag(ctx, s.topic) + dgls, err := ac.Lag(ctx, s.opts.Group) if err != nil || !dgls.Ok() { continue }