This is an automated email from the ASF dual-hosted git repository. zike pushed a commit to branch branch-0.11.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
commit c70a7b2f11fff62ff86170411446f5a5be48221d Author: gunli <[email protected]> AuthorDate: Wed Jul 5 10:20:03 2023 +0800 [Fix] return when registerSendOrAckOp() failed (#1045) Master Issue: #1040 ### Motivation fix #1040, return when registerSendOrAckOp() return an error. ### Modifications - modified: pulsar/producer_partition.go --------- Co-authored-by: gunli <[email protected]> (cherry picked from commit aa664716ac0bfb886c756f33ba72376092e8e3a5) --- pulsar/producer_partition.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go index 00d4e6f0..b416c9ec 100755 --- a/pulsar/producer_partition.go +++ b/pulsar/producer_partition.go @@ -1145,6 +1145,7 @@ func (p *partitionProducer) internalSendAsync(ctx context.Context, msg *Producer } if err := transactionImpl.registerSendOrAckOp(); err != nil { runCallback(callback, nil, msg, err) + return } newCallback = func(id MessageID, producerMessage *ProducerMessage, err error) { runCallback(callback, id, producerMessage, err)
