Skip to content

Commit

Permalink
Fix test
Browse files Browse the repository at this point in the history
Signed-off-by: Marco Pracucci <marco@pracucci.com>
  • Loading branch information
pracucci committed Nov 13, 2024
1 parent 2cc97aa commit 6e166d7
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion pkg/storage/ingest/fetcher_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)

Expand Down

0 comments on commit 6e166d7

Please sign in to comment.