continue when reader run get a OffsetOutOfRange

segmentio · Sep 14, 2017 · 49dc912 · 49dc912
1 parent 0a19498
commit 49dc912
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/reader.go b/reader.go
@@ -390,6 +390,7 @@ func (r *reader) run(ctx context.Context, offset int64, join *sync.WaitGroup) {
 			r.withLogger(func(log *log.Logger) {
 				log.Printf("error initializing the kafka reader for partition %d of %s: %s", r.partition, r.topic, OffsetOutOfRange)
 			})
+			continue
 		default:
 			// Wait 4 attempts before reporting the first errors, this helps
 			// mitigate situations where the kafka server is temporarily