diff --git a/pkg/storage/ingest/reader.go b/pkg/storage/ingest/reader.go index 391cac4e07..581b1ae69b 100644 --- a/pkg/storage/ingest/reader.go +++ b/pkg/storage/ingest/reader.go @@ -953,11 +953,9 @@ func newConcurrentFetchers( f := &concurrentFetchers{ client: client, logger: logger, - concurrency: concurrency, topicName: topic, partitionID: partition, metrics: metrics, - recordsPerFetch: recordsPerFetch, minBytesWaitTime: minBytesWaitTime, lastReturnedRecord: noReturnedRecords, startOffsets: startOffsetsReader, @@ -996,10 +994,6 @@ func newConcurrentFetchers( } func (r *concurrentFetchers) Update(ctx context.Context, concurrency, records int) { - if r.concurrency == concurrency && r.recordsPerFetch == records { - return - } - r.Stop() r.done = make(chan struct{})