Improve reader error messages

trampfox · Jan 19, 2021 · 2b3f682 · 2b3f682
1 parent 2b9123d
commit 2b3f682
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/reader.go b/reader.go
@@ -1083,7 +1083,7 @@ func (r *Reader) readLag(ctx context.Context) {
 		if err != nil {
 			r.stats.errors.observe(1)
 			r.withErrorLogger(func(log Logger) {
-				log.Printf("kafka reader failed to read lag of partition %d of %s", r.config.Partition, r.config.Topic)
+				log.Printf("kafka reader failed to read lag of partition %d of %s: %s", r.config.Partition, r.config.Topic, err)
 			})
 		} else {
 			r.stats.lag.observe(lag)