context background for ProduceSync

ozontech · Jul 18, 2024 · 25e557d · 25e557d
1 parent cc6e3cd
commit 25e557d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugin/output/kafka/kafka.go b/plugin/output/kafka/kafka.go
@@ -322,7 +322,7 @@ func (p *Plugin) out(workerData *pipeline.WorkerData, batch *pipeline.Batch) err
 		i++
 	})
 
-	if err := p.client.ProduceSync(context.TODO(), data.messages[:i]...).FirstErr(); err != nil {
+	if err := p.client.ProduceSync(context.Background(), data.messages[:i]...).FirstErr(); err != nil {
 		p.logger.Errorf("can't write batch: %v", err)
 		p.sendErrorMetric.Inc()
 		return err