Skip to content

Commit

Permalink
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions reader.go
Original file line number Diff line number Diff line change
@@ -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

0 comments on commit 49dc912

Please sign in to comment.