Remove redundant panic

Signed-off-by: Dimitar Dimitrov <[email protected]>
grafana · Oct 2, 2024 · de335b8 · de335b8
1 parent d8dcfc7
commit de335b8
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/pkg/storage/ingest/reader.go b/pkg/storage/ingest/reader.go
@@ -285,10 +285,6 @@ func (r *PartitionReader) switchToOngoingFetcher(ctx context.Context) {
 			r.kafkaCfg.Topic: {r.partitionID: kgo.NewOffset().At(lastConsumed + 1)},
 		})
 	}
-
-	if r.kafkaCfg.StartupFetchConcurrency == 0 && r.kafkaCfg.OngoingFetchConcurrency > 0 {
-		panic("this shouldn't have been allowed through config validation; we can only use concurrent fetchers for ongoing fetches if they're also used for startup fetches")
-	}
 }
 
 func (r *PartitionReader) processNextFetches(ctx context.Context, delayObserver prometheus.Observer) error {