group: avoid concurrently setting err; use better log message

twmb · Mar 29, 2021 · d74bbc3 · d74bbc3
1 parent ca32e19
commit d74bbc3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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)