diff --git a/producer/producer.go b/producer/producer.go index 2cbeff68..9ea17e3d 100644 --- a/producer/producer.go +++ b/producer/producer.go @@ -754,7 +754,7 @@ func (tp *transactionProducer) endTransaction(result primitive.SendResult, err e } else { msgID, _ = primitive.UnmarshalMsgID([]byte(result.MsgID)) } - // 估计没有反序列化回来 + brokerAddr := tp.producer.client.GetNameSrv().FindBrokerAddrByName(result.MessageQueue.BrokerName) requestHeader := &internal.EndTransactionRequestHeader{ TransactionId: result.TransactionID,