diff --git a/reader.go b/reader.go
index 0b124c203..0c3d55e97 100644
--- a/reader.go
+++ b/reader.go
@@ -1266,7 +1266,7 @@ func (r *reader) run(ctx context.Context, offset int64) {
 				break readLoop
 
 			case io.EOF:
-				r.withLogger(func(log *log.Logger) {
+				r.withLogger(func(log Logger) {
 					log.Printf("the kafka reader got an EOF for partition %d of %s at offset %d: %s", r.partition, r.topic, offset, err)
 				})
 				r.stats.errors.observe(1)