diff --git a/pkg/storage/ingest/fetcher_test.go b/pkg/storage/ingest/fetcher_test.go
index af0117fb65c..ace16bd3673 100644
--- a/pkg/storage/ingest/fetcher_test.go
+++ b/pkg/storage/ingest/fetcher_test.go
@@ -772,7 +772,7 @@ func TestConcurrentFetchers(t *testing.T) {
 		t.Logf("Records fetched: %d", len(fetchedRecords))
 	})
 
-	t.Run("staggered production with exact multiple of concurrency and records per fetch", func(t *testing.T) {
+	t.Run("staggered production", func(t *testing.T) {
 		t.Parallel()
 
 		ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
diff --git a/pkg/storage/ingest/reader.go b/pkg/storage/ingest/reader.go
index d33916a17ae..9a4bf73426b 100644
--- a/pkg/storage/ingest/reader.go
+++ b/pkg/storage/ingest/reader.go
@@ -318,7 +318,7 @@ func (r *PartitionReader) switchToOngoingFetcher(ctx context.Context) {
 	}
 
 	if r.kafkaCfg.StartupFetchConcurrency > 0 && r.kafkaCfg.OngoingFetchConcurrency > 0 {
-		// No need to switch the fetcher, just update the records per fetch.
+		// No need to switch the fetcher, just update the concurrency.
 		r.getFetcher().Update(ctx, r.kafkaCfg.OngoingFetchConcurrency)
 		return
 	}