Restore the early return

apache · Feb 16, 2023 · b25d861 · b25d861
1 parent 94c2fba
commit b25d861
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
@@ -812,6 +812,7 @@ func (pc *partitionConsumer) internalAck(req *ackRequest) {
 			pc.log.WithError(err).Error("Ack with response error")
 			req.err = err
 		}
+		return
 	}
 
 	err := pc.client.rpcClient.RequestOnCnxNoWait(pc._getConn(), pb.BaseCommand_ACK, cmdAck)