Fix data race between kafkareceiver and batchprocessor (#2956) (#2957)

open-telemetry · Apr 19, 2021 · 4e1fd23 · 4e1fd23
1 parent 90b2dec
commit 4e1fd23
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/receiver/kafkareceiver/kafka_receiver.go b/receiver/kafkareceiver/kafka_receiver.go
@@ -171,8 +171,9 @@ func (c *consumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession,
 			return err
 		}
 
+		spanCount := traces.SpanCount()
 		err = c.nextConsumer.ConsumeTraces(session.Context(), traces)
-		obsreport.EndTraceDataReceiveOp(ctx, c.unmarshaller.Encoding(), traces.SpanCount(), err)
+		obsreport.EndTraceDataReceiveOp(ctx, c.unmarshaller.Encoding(), spanCount, err)
 		if err != nil {
 			return err
 		}