update error

apache · Jul 11, 2023 · e72a275 · e72a275
1 parent a6cca75
commit e72a275
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -1114,7 +1114,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
 	}