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)