From 918256ced402839c2cc59012c1115d90c870e780 Mon Sep 17 00:00:00 2001
From: gotjosh <josue.abreu@gmail.com>
Date: Thu, 26 Sep 2024 20:39:43 +0100
Subject: [PATCH] don't store concurrency or records per fetch

Signed-off-by: gotjosh <josue.abreu@gmail.com>
---
 pkg/storage/ingest/reader.go | 6 ------
 1 file changed, 6 deletions(-)

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{})