Fix send duplicate message in trace interceptor (#709)

apache · Aug 12, 2021 · 077cd3b · 077cd3b
1 parent 46701f1
commit 077cd3b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/producer/interceptor.go b/producer/interceptor.go
@@ -50,7 +50,7 @@ func newTraceInterceptor(traceCfg *primitive.TraceConfig) primitive.Interceptor
 
 		producerCtx := primitive.GetProducerCtx(ctx)
 		if producerCtx.Message.Topic == dispatcher.GetTraceTopicName() {
-			return next(ctx, req, reply)
+			return err
 		}
 
 		// SendOneway && SendAsync has no reply.