Fix cnx

apache · Jul 12, 2024 · 7cb37cd · 7cb37cd
1 parent e7847b4
commit 7cb37cd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -301,7 +301,7 @@ func (p *partitionProducer) grabCnx(assignedBrokerURL string) error {
 		p.log.WithError(err).Error("Failed to create producer at send PRODUCER request")
 		if errors.Is(err, internal.ErrRequestTimeOut) {
 			id := p.client.rpcClient.NewRequestID()
-			_, _ = p.client.rpcClient.RequestOnCnx(res.Cnx, id, pb.BaseCommand_CLOSE_PRODUCER,
+			_, _ = p.client.rpcClient.RequestOnCnx(cnx, id, pb.BaseCommand_CLOSE_PRODUCER,
 				&pb.CommandCloseProducer{
 					ProducerId: &p.producerID,
 					RequestId:  &id,