Update comments and test names

Signed-off-by: Dimitar Dimitrov <[email protected]>

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)

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
 	}