diff --git a/kafka_receiver.go b/kafka_receiver.go
index d6f42b6777a6..c811b2234edb 100644
--- a/kafka_receiver.go
+++ b/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
 		}