From d74bbc37807e6764fbca6a2a13ce9eba49587114 Mon Sep 17 00:00:00 2001 From: Travis Bischel Date: Mon, 22 Mar 2021 03:10:10 -0600 Subject: [PATCH] group: avoid concurrently setting err; use better log message --- pkg/kgo/consumer_group.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/kgo/consumer_group.go b/pkg/kgo/consumer_group.go index 2c71ba78..74b2f8e6 100644 --- a/pkg/kgo/consumer_group.go +++ b/pkg/kgo/consumer_group.go @@ -1226,7 +1226,8 @@ start: select { case <-fetchDone: case <-ctx.Done(): - err = ctx.Err() + g.cl.cfg.logger.Log(LogLevelError, "fetch offsets failed due to context cancelation") + return ctx.Err() } if err != nil { g.cl.cfg.logger.Log(LogLevelError, "fetch offsets failed with non-retriable error", "err", err)