Remove unused PartitionReader.Topic() method

grafana · Dec 20, 2024 · d3c9d1d · d3c9d1d
1 parent 1606525
commit d3c9d1d
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/pkg/storage/ingest/reader.go b/pkg/storage/ingest/reader.go
@@ -130,10 +130,6 @@ func newPartitionReader(kafkaCfg KafkaConfig, partitionID int32, instanceID stri
 	return r, nil
 }
 
-func (r *PartitionReader) Topic() string {
-	return r.kafkaCfg.Topic
-}
-
 // Stop implements fetcher
 func (r *PartitionReader) Stop() {
 	// Given the partition reader has no concurrency it doesn't support stopping anything.