From 4e1fd234d1608a6a5745f33e40cf5ac3f387df83 Mon Sep 17 00:00:00 2001 From: hanjm Date: Tue, 20 Apr 2021 00:15:13 +0800 Subject: [PATCH] Fix data race between kafkareceiver and batchprocessor (#2956) (#2957) --- receiver/kafkareceiver/kafka_receiver.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/receiver/kafkareceiver/kafka_receiver.go b/receiver/kafkareceiver/kafka_receiver.go index d6f42b6777a..c811b2234ed 100644 --- 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 }