fix context

open-telemetry · Sep 6, 2024 · fd12dd2 · fd12dd2
1 parent a35c776
commit fd12dd2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/receiver/kafkareceiver/kafka_receiver.go b/receiver/kafkareceiver/kafka_receiver.go
@@ -238,7 +238,7 @@ func newMetricsReceiver(config Config, set receiver.Settings, unmarshaler Metric
 	}, nil
 }
 
-func (c *kafkaMetricsConsumer) Start(ctx context.Context, host component.Host) error {
+func (c *kafkaMetricsConsumer) Start(_ context.Context, host component.Host) error {
 	ctx, cancel := context.WithCancel(context.Background())
 	c.cancelConsumeLoop = cancel
 	obsrecv, err := receiverhelper.NewObsReport(receiverhelper.ObsReportSettings{
@@ -332,7 +332,7 @@ func newLogsReceiver(config Config, set receiver.Settings, unmarshaler LogsUnmar
 	}, nil
 }
 
-func (c *kafkaLogsConsumer) Start(ctx context.Context, host component.Host) error {
+func (c *kafkaLogsConsumer) Start(_ context.Context, host component.Host) error {
 	ctx, cancel := context.WithCancel(context.Background())
 	c.cancelConsumeLoop = cancel
 	obsrecv, err := receiverhelper.NewObsReport(receiverhelper.ObsReportSettings{