chore: refactor

open-telemetry · Jan 14, 2025 · 90814f2 · 90814f2
1 parent 0465509
commit 90814f2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/exporter/kafkaexporter/kafka_exporter.go b/exporter/kafkaexporter/kafka_exporter.go
@@ -53,7 +53,7 @@ func (e *kafkaTracesProducer) tracesPusher(ctx context.Context, td ptrace.Traces
 	var allErrors []string
 
 	for i, chunk := range messageChunks {
-		sendErr := e.producer.SendMessages(chunk.msg)
+		sendErr := e.producer.SendMessages(chunk.Messages)
 		if sendErr == nil {
 			continue
 		}