update error

apache · Jul 7, 2023 · f9498e0 · f9498e0
1 parent 0c4cd03
commit f9498e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -1110,7 +1110,7 @@ func (p *partitionProducer) internalSendAsync(ctx context.Context, msg *Producer
 
 	if msg.Value != nil && msg.Payload != nil {
 		p.log.Error("Can not set Value and Payload both")
-		runCallback(callback, nil, msg, errors.New("can not set Value and Payload both"))
+		runCallback(callback, nil, msg, newError(InvalidMessage, "Can not set Value and Payload both"))
 		return
 	}