From 6e166d7112b08977eeb5d4e6c4aed6a729d2d9d0 Mon Sep 17 00:00:00 2001 From: Marco Pracucci Date: Wed, 13 Nov 2024 09:54:26 +0100 Subject: [PATCH] Fix test Signed-off-by: Marco Pracucci --- pkg/storage/ingest/fetcher_test.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/storage/ingest/fetcher_test.go b/pkg/storage/ingest/fetcher_test.go index c20040a5265..5eda6a258e1 100644 --- a/pkg/storage/ingest/fetcher_test.go +++ b/pkg/storage/ingest/fetcher_test.go @@ -923,7 +923,9 @@ func TestConcurrentFetchers(t *testing.T) { logger := log.NewNopLogger() reg := prometheus.NewPedanticRegistry() - metrics := newReaderMetrics(partitionID, reg) + metrics := newReaderMetrics(partitionID, reg, func() float64 { + return 0 + }) client := newKafkaProduceClient(t, clusterAddr)