Remove last mentions of ifc

grafana · Nov 22, 2024 · a61738d · a61738d
1 parent 3cc3db9
commit a61738d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/pkg/kafka/client/reader_client.go b/pkg/kafka/client/reader_client.go
@@ -36,7 +36,7 @@ func NewReaderClient(kafkaCfg kafka.Config, metrics *kprom.Metrics, logger log.L
 	)
 	client, err := kgo.NewClient(opts...)
 	if err != nil {
-		return nil, errors.Wrap(err, "creating kafka client")
+		return nil, fmt.Errorf("creating kafka client: %w", err)
 	}
 	if kafkaCfg.AutoCreateTopicEnabled {
 		setDefaultNumberOfPartitionsForAutocreatedTopics(kafkaCfg, client, logger)

diff --git a/pkg/kafka/partition/reader_service.go b/pkg/kafka/partition/reader_service.go
@@ -91,10 +91,10 @@ func NewReaderService(
 	)
 
 	if err != nil {
-		return nil, errors.Wrap(err, "creating kafka reader")
+		return nil, fmt.Errorf("creating kafka reader: %w", err)
 	}
 
-	return newReaderServiceFromIfc(
+	return newReaderService(
 		ReaderConfig{
 			TargetConsumerLagAtStartup:    kafkaCfg.TargetConsumerLagAtStartup,
 			MaxConsumerLagAtStartup:       kafkaCfg.MaxConsumerLagAtStartup,
@@ -107,7 +107,7 @@ func NewReaderService(
 	), nil
 }
 
-func newReaderServiceFromIfc(
+func newReaderService(
 	cfg ReaderConfig,
 	reader Reader,
 	consumerFactory ConsumerFactory,