Log EOF errors to standard logger (segmentio#294)

They were being logged to the error logger, which caused error-level logs to be written frequently when topics had no messages to consume.
ghostsusan · Sep 16, 2019 · 602d499 · 602d499
1 parent 0430ada
commit 602d499
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/reader.go b/reader.go
@@ -1266,6 +1266,14 @@ func (r *reader) run(ctx context.Context, offset int64) {
 				r.sendError(ctx, err)
 				break readLoop
 
+			case io.EOF:
+				r.withLogger(func(log *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)
+				conn.Close()
+				break readLoop
+
 			default:
 				if _, ok := err.(Error); ok {
 					r.sendError(ctx, err)