[fix] set useTxn when use transaction

apache · Jun 30, 2023 · c40581d · c40581d
1 parent 8d34019
commit c40581d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -707,6 +707,7 @@ func addRequestToBatch(smm *pb.SingleMessageMetadata, p *partitionProducer,
 	var leastSigBits uint64
 	if request.transaction != nil {
 		txnID := request.transaction.GetTxnID()
+		useTxn = true
 		mostSigBits = txnID.MostSigBits
 		leastSigBits = txnID.LeastSigBits
 	}
@@ -813,6 +814,7 @@ func (p *partitionProducer) internalSingleSend(mm *pb.MessageMetadata,
 
 	if request.transaction != nil {
 		txnID := request.transaction.GetTxnID()
+		useTxn = true
 		mostSigBits = txnID.MostSigBits
 		leastSigBits = txnID.LeastSigBits
 	}