fix: the var of span occurrence Unexpected.#571 (#572)

douyu · Nov 21, 2022 · c472fd9 · c472fd9
1 parent 7f255f8
commit c472fd9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/client/rocketmq/consumer.go b/pkg/client/rocketmq/consumer.go
@@ -189,7 +189,9 @@ func (cc *PushConsumer) RegisterSingleMessage(f func(context.Context, *primitive
 			err := f(ctx, msg)
 			if err != nil {
 				xlog.Jupiter().Error("consumer message", zap.Error(err), zap.String("field", cc.name), zap.Any("ext", msg))
-				span.RecordError(err)
+				if cc.EnableTrace && span != nil {
+					span.RecordError(err)
+				}
 				return consumer.ConsumeRetryLater, err
 			}
 		}